t
Subscriptions
trait Subscriptions[Msg]Defined by scalive.Subscriptions. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:74-87)
Methods3
cancel
def cancel(key: SubscriptionKey): zio.package.Task[Unit]Defined by scalive.Subscriptions.cancel. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:87-87)
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:81-86)
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:75-80)