BroadcastByKey

libretto.scaletto.ScalettoStreams.Pollable$.BroadcastByKey$

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Concise view

Value members

Concrete methods

def close[K, V]: BroadcastByKey[K, V] -⚬ Done
def subscribe[K, V](k: K): BroadcastByKey[K, V] -⚬ BroadcastByKey[K, V] |*| Pollable[V]