Skip to content
scalive
Menu
ConnectingLiveReconnectingOffline
t

Streams

trait Streams

Defined by scalive.Streams. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:49-68)

Methods6

create

def create[A, Id](definition: streams.LiveStreamDef[A, Id], items: Iterable[A]): zio.package.Task[streams.LiveStream[A]]

Defined by scalive.Streams.create. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:50-50)

delete

def delete[A, Id](definition: streams.LiveStreamDef[A, Id], id: Id): zio.package.Task[streams.LiveStream[A]]

Defined by scalive.Streams.delete. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:67-67)

deleteByDomId

def deleteByDomId[A, Id](definition: streams.LiveStreamDef[A, Id], domId: String): zio.package.Task[streams.LiveStream[A]]

Defined by scalive.Streams.deleteByDomId. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:68-68)

insert

def insert[A, Id](definition: streams.LiveStreamDef[A, Id], item: A, at: streams.StreamAt = ..., updateOnly: Boolean = ...): zio.package.Task[streams.LiveStream[A]]

Defined by scalive.Streams.insert. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:61-66)

insertAll

def insertAll[A, Id](definition: streams.LiveStreamDef[A, Id], items: Iterable[A], at: streams.StreamAt = ...): zio.package.Task[streams.LiveStream[A]]

Defined by scalive.Streams.insertAll. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:51-55)

reset

def reset[A, Id](definition: streams.LiveStreamDef[A, Id], items: Iterable[A], at: streams.StreamAt = ...): zio.package.Task[streams.LiveStream[A]]

Defined by scalive.Streams.reset. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:56-60)