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

Defined in:

movie/streams_typed.cr

Constructors

.new(ref : ActorRef(MessageBase(T)), subscriber : ActorRefBase | Nil = nil)

Instance Method Summary

#cancel
#request(n : UInt64)

Constructor Detail

def self.new(ref : ActorRef(MessageBase(T)), subscriber : ActorRefBase | Nil = nil) #

[View source]

Instance Method Detail

def cancel #

[View source]

def request(n : UInt64) #

[View source]