OutPorts

libretto.CoreExecution.OutPorts
trait OutPorts

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def awaitDone(port: OutPort[Done]): Async[Either[Throwable, Unit]]
def awaitEither[A, B](port: OutPort[A |+| B]): Async[Either[Throwable, Either[OutPort[A], OutPort[B]]]]
def awaitNoPing(port: OutPort[Ping], duration: FiniteDuration): Async[Either[Either[Throwable, Unit], OutPort[Ping]]]
def awaitPing(port: OutPort[Ping]): Async[Either[Throwable, Unit]]
def chooseLeft[A, B](port: OutPort[A |&| B]): OutPort[A]
def chooseRight[A, B](port: OutPort[A |&| B]): OutPort[B]
def constant[A](obj: One -⚬ A): OutPort[A]
def discardOne(port: OutPort[One]): Unit
def map[A, B](port: OutPort[A])(f: A -⚬ B): OutPort[B]
def pair[A, B](a: OutPort[A], b: OutPort[B]): OutPort[A |*| B]
def split[A, B](port: OutPort[A |*| B]): (OutPort[A], OutPort[B])
def supplyNeed(port: OutPort[Need]): Unit
def supplyPong(port: OutPort[Pong]): Unit

Deprecated methods

def sendPong(port: OutPort[Pong]): Unit

Attributes

Deprecated
true