class Movie::Streams::Typed::CompletionFlow(T)

Movie::Streams::Typed::CompletionFlow(T)
Movie::AbstractBehavior(Movie::Streams::Typed::MessageBase(T))
Reference
Object

Defined in:

movie/streams_typed.cr

Constructors

.new(promise : Promise(Nil))

Instance Method Summary

#receive(message : MessageBase(T), context : ActorContext(MessageBase(T)))

Instance methods inherited from class `Movie::AbstractBehavior(Movie::Streams::Typed::MessageBase(T))`

,

Constructor Detail

def self.new(promise : Promise(Nil)) #

[View source]

Instance Method Detail

def receive(message : MessageBase(T), context : ActorContext(MessageBase(T))) #

[View source]