lib/zapp/pipe.rb in zapp-0.2.4 vs lib/zapp/pipe.rb in zapp-0.2.5

- old
+ new

@@ -1,11 +1,11 @@ # frozen_string_literal: true module Zapp # Light wrapper around a Ractor for piping messages CSP style - module Pipe + class Pipe < Ractor def self.new - Ractor.new do + super do loop do Ractor.yield(Ractor.receive) end end end