struct Movie::Streams::Typed::BroadcastHub::SubscriberState(T)

Defined in:

movie/streams_typed.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(ref : ActorRef(MessageBase(T)), demand : UInt64) #

[View source]

Instance Method Detail

def clone #

[View source]
def copy_with(ref _ref = @ref, demand _demand = @demand) #

[View source]
def demand : UInt64 #

def ref : ActorRef(MessageBase(T)) #