class Onyx::EDA::Channel::Memory

Overview

An in-memory channel. Emitted events are visible within current process only.

Defined in:

onyx-eda/channel/memory.cr

Instance Method Summary

Instance methods inherited from class Onyx::EDA::Channel

await(event : T.class, **filter, &block : T -> U) : U forall T, U
await(event, **filter)
await
, emit(events : Enumerable) : Enumerable
emit(event : T) : T forall T
emit(*events) : Enumerable
emit
, subscribe(event : T.class, consumer_id : String, &block : T -> UNDERSCORE) : Onyx::EDA::Channel::Subscription(T) forall T
subscribe(event : T.class, **filter, &block : T -> UNDERSCORE) : Onyx::EDA::Channel::Subscription(T) forall T
subscribe
, unsubscribe(subscription : Subscription) : Bool unsubscribe

Instance Method Detail

def emit(events : Enumerable(T)) : Enumerable(T) forall T #

[View source]
def emit(event : T) : T forall T #

[View source]
def emit(*events : *T) : Enumerable forall T #

[View source]
def subscribe(event : T.class, consumer_id : String, **filter, &block : T -> UNDERSCORE) : Onyx::EDA::Channel::Subscription(T) forall T #

[View source]
def subscribe(event : T.class, **filter, &block : T -> UNDERSCORE) : Onyx::EDA::Channel::Subscription(T) forall T #

[View source]
def unsubscribe(subscription : Subscription) : Bool #

[View source]