class Cl::Async::Job(I, O)

Included Modules

Defined in:

async/job.cr

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from module Cl::Miscs::WithSelf

with_self(*args, **kwargs, &) with_self

Class methods inherited from module Cl::Miscs::WithSelf

with_new(*args, **kwargs, &) with_new

Instance methods inherited from module Cl::Patterns::Publisher(O)

subscribe(&block : O -> ) subscribe, unsubscribe(block : Proc(O, Void)) unsubscribe

Instance methods inherited from class Cl::Async::Spawner

dead? dead?, handler handler, start start, stop stop

Constructor methods inherited from class Cl::Async::Spawner

new(name : String | Nil = nil, delay : Time::Span = Time::Span::ZERO)
new(*, name : String | Nil = nil, delay : Time::Span = Time::Span::ZERO, &proc : -> ) new

Class methods inherited from class Cl::Async::Spawner

start(**kwargs, &proc : -> )
start(**kwargs) start

Constructor Detail

def self.new(buffer = 0, **kwargs) #

[View source]
def self.new(**kwargs, &function_block : I -> O) #

[View source]

Class Method Detail

def self.start(**kwargs, &function_block : I -> O) #

[View source]

Instance Method Detail

def <<(other : Job(O, Object)) #

[View source]
def >>(other : Job(O, Object)) #

[View source]
def close #

[View source]
def function(&function_block : I -> O) #

[View source]
def function(input : I) #

[View source]
def handler #

[View source]
def publish(item : O) #

[View source]
def send(message : I) #

[View source]
def subscribe_to(other : Job(Object, I)) #

[View source]