OutPorts

libretto.CoreExecution.OutPorts
trait OutPorts

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Concise view

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 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 discardOne(port: OutPort[One]): Unit
def map[A, B](port: OutPort[A])(f: A -⚬ B): OutPort[B]
def split[A, B](port: OutPort[A |*| B]): (OutPort[A], OutPort[B])