t
Subscriptions
trait Subscriptions[Msg]Defined by scalive.Subscriptions. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:75-88)
Methods3
cancel
def cancel(key: SubscriptionKey): zio.package.Task[Unit]Defined by scalive.Subscriptions.cancel. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:88-88)
replace
def replace(key: SubscriptionKey, delivery: SubscriptionDelivery)(stream: zio.stream.ZStream[Any, Nothing, Msg]): zio.package.Task[Unit]Defined by scalive.Subscriptions.replace. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:82-87)
start
def start(key: SubscriptionKey, delivery: SubscriptionDelivery)(stream: zio.stream.ZStream[Any, Nothing, Msg]): zio.package.Task[Unit]Defined by scalive.Subscriptions.start. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:76-81)