class
Movie::Streams::Typed::CollectSink(T)
- Movie::Streams::Typed::CollectSink(T)
- Movie::AbstractBehavior(Movie::Streams::Typed::MessageBase(T))
- Reference
- Object
Defined in:
movie/streams_typed.crConstructors
Instance Method Summary
- #on_signal(signal : SystemMessage)
- #receive(message : MessageBase(T), context : ActorContext(MessageBase(T)))
- #state : Streams::StageState
Instance methods inherited from class Movie::AbstractBehavior(Movie::Streams::Typed::MessageBase(T))
on_signal(signal : SystemMessage)
on_signal,
receive(message : T(T), context : ActorContext(T(T)))
receive
Constructor Detail
def self.new(output : Channel(T), signals : Channel(Symbol) | Nil = nil, delivery_control : DeliveryControl = DeliveryControl.new)
#