libretto
API
Generated with
© 2002-2021 · LAMP/EPFL
© 2002-2021 · LAMP/EPFL
libretto/libretto/CoreStreams/LPolled

LPolled

libretto.CoreStreams.LPolled$
object LPolled

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type
LPolled.type

Members list

Concise view

Value members

Concrete methods

def close[A](neglect: A -⚬ Done): LPolled[A] -⚬ Done
def cons[A]: A |*| LPollable[A] -⚬ LPolled[A]
def delayBy[A](implicit ev: Positive[A]): Done |*| LPolled[A] -⚬ LPolled[A]
def delayClosedBy[A](delayLPollableClosed: Done |*| LPollable[A] -⚬ LPollable[A]): Done |*| LPolled[A] -⚬ LPolled[A]
def empty[A]: Done -⚬ LPolled[A]
def feedTo[A, B](f: A |*| B -⚬ PMaybe[B]): LPolled[A] |*| B -⚬ Done |*| Maybe[B]
def merge[A](mergePollables: LPollable[A] |*| LPollable[A] -⚬ LPollable[A])(implicit A1: Positive[A], A2: PAffine[A]): LPolled[A] |*| LPolled[A] -⚬ LPolled[A]

Merges two LPolleds into one. Left-biased: whenever there is a value available from both upstreams, favors the first one.

Merges two LPolleds into one. Left-biased: whenever there is a value available from both upstreams, favors the first one.

Attributes

mergePollables

left-biased merge of two LPollables.

def switch[A, R](caseEmpty: Done -⚬ R, caseCons: A |*| LPollable[A] -⚬ R): LPolled[A] -⚬ R
def unpoll[A](implicit A: PAffine[A]): LPolled[A] -⚬ LPollable[A]

Implicits

Implicits

implicit def positiveLPolled[A](implicit A: Positive[A]): Positive[LPolled[A]]
Generated with
© 2002-2021 · LAMP/EPFL
© 2002-2021 · LAMP/EPFL