Module: FiberStream::RactorPort
- Defined in:
- lib/fiber_stream/ractor_port.rb
Overview
Typed message envelopes for ‘Source.ractor_port`.
Producers send ‘Element`, `Complete`, and `Failure` messages to the data port. FiberStream sends `Ack` and `Cancel` messages to the producer-owned acknowledgment port. The envelopes keep stream values distinct from control messages and support Ruby pattern matching.