ZIO Pravega
0.11.2+6-0241b274-SNAPSHOT
DocsAPI
Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER
ZIO Pravega/zio/zio.pravega/zio.pravega.saga/StreamService

StreamService

zio.pravega.saga.StreamService
trait StreamService

A stream service is a service that is implemented as a stream of events.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def serviceLoop[R, Event, Error](eventStream: ZStream[PravegaStream, Error, Event])(handler: Event => ZIO[R, Error, Unit]): ZIO[PravegaStream & R, Error, Unit]

A stream of commands.

A stream of commands.

Value parameters

eventStream

stream of events

handler

function to execute the command

Attributes

Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER