Streams
trait StreamsDefined by scalive.Streams. View source (scalive/api/src/scalive/lifecycle/Capabilities.scala:50-69)
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:51-51)
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:68-68)
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:69-69)
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:62-67)
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:52-56)
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:57-61)