InPorts

libretto.CoreExecution.InPorts
trait InPorts

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def constant[A](f: A -⚬ One): InPort[A]
def contramap[A, B](port: InPort[B])(f: A -⚬ B): InPort[A]
def discardOne(port: InPort[One]): Unit
def pair[A, B](a: InPort[A], b: InPort[B]): InPort[A |*| B]
def split[A, B](port: InPort[A |*| B]): (InPort[A], InPort[B])
def supplyChoice[A, B](port: InPort[A |&| B]): Async[Either[Throwable, Either[InPort[A], InPort[B]]]]
def supplyDone(port: InPort[Done]): Unit
def supplyLeft[A, B](port: InPort[A |+| B]): InPort[A]
def supplyPing(port: InPort[Ping]): Unit
def supplyRight[A, B](port: InPort[A |+| B]): InPort[B]