Skip to content
scalive
Menu
ConnectingLiveReconnectingOffline
t

LiveDisconnectBus

trait LiveDisconnectBus[Id]

Cluster fanout for active LiveView session invalidation.

A subscription must be ready to receive notifications when subscribe returns and remains active for the lifetime of its enclosing scope. Implementations must fan each publication out to every subscriber; competing-consumer delivery is not sufficient.

Defined by scalive.LiveDisconnectBus. View source (scalive/api/src/scalive/LiveDisconnectBus.scala:11-14)

Methods2

publish

def publish(id: Id): zio.package.Task[Unit]

Defined by scalive.LiveDisconnectBus.publish. View source (scalive/api/src/scalive/LiveDisconnectBus.scala:12-12)

subscribe

def subscribe(onDisconnect: Id => zio.package.UIO[Unit]): zio.ZIO[zio.Scope, Throwable, Unit]

Defined by scalive.LiveDisconnectBus.subscribe. View source (scalive/api/src/scalive/LiveDisconnectBus.scala:14-14)