Instance methods inherited from module Fluxite::IFanout(T)

connect(other : IMailbox(T)) : Nil connect, disconnect(other : IMailbox(T)) : Nil disconnect, send(queue, cls : T.class, object : T) : Nil send

Instance methods inherited from module Fluxite::PipeOut(T)

after(other : IFanout(U)) forall U after, batch(&fn : Array(T), T -> Cut)
batch(n : Int) batch, before(other : IFanout(U)) forall U before, blast(&fn : T -> Enumerable(U)) forall U blast, compact_map(&fn : T -> U | Nil) forall U compact_map, cord : Cord(T)
cord(*, to other : Port(T)) : Cord(T) cord, during(gate : IFanout(Bool)) during, each(&fn : T -> ) each, forward(cls : U.class, &fn : T, Forward::Feed(U) -> ) forall U forward, gate(*, by other : IFanout(Bool)) gate, into(other : IFanout(U), as cls : U.class) : self forall U
into(other : IMailbox(T))
into(other : IMailbox(U)) forall U
into(other : IFanout(U), &fn : T -> U) : self forall U
into(receiver, &fn : T -> U) : Nil forall T, U
into(&fn : T -> Enumerable(IMailbox(T))) : Nil
into(receiver) : Nil into, map(&fn : T -> U) forall U
map(cls : U.class) forall U
map(*layout : *U) forall U map, only(*args, **kwargs, &fn : T -> Bool)
only(*args, **kwargs) only, or(other : IFanout(U)) forall U or, partition(&fn : T -> Bool) partition, port : Port(T) port, recent(&fn : Array(T), T -> Cut) recent, reject(&fn : T -> Bool)
reject(pattern) reject, select(&fn : T -> Bool)
select(as cls : U.class) forall U
select(pattern) select, squash(initial : T, &fn : T, T -> Bool)
squash(&fn : T, T -> Bool)
squash(*args, **kwargs) squash, squash_by(initial : U, &fn : T -> U) forall U
squash_by(&fn : T -> U) forall U squash_by, track(other : IFanout(U), default : U) forall U
track(other : IFanout(U)) forall U
track(*layout : *U) forall U track, upto(n : Int) upto

Instance methods inherited from module Fluxite::IMailbox(T)

receive(queue, sender : Unit, object : T) : Nil receive

Class methods inherited from module Fluxite::Unit

connect(a : IFanout(T), *, to b : IMailbox(T)) forall T connect, disconnect(b : IMailbox(T), *, from a : IFanout(T)) forall T disconnect, join(*units) join, pass(unit : IFanout(T), object : T) : Nil forall T pass, passall(unit : IFanout(T), objects : Enumerable(T)) forall T passall