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