Header menu logo FCQRS

Internal Module

Functions and values

Function or value Description

readJournal system

Full Usage: readJournal system

Parameters:
Returns: SqlReadJournal
system : ActorSystem
Returns: SqlReadJournal

subscribeCmd source actorApi cb

Full Usage: subscribeCmd source actorApi cb

Parameters:
    source : Source<'TDataEvent, unit>
    actorApi : IActor
    cb : 'TDataEvent -> unit

Returns: IKillSwitch
source : Source<'TDataEvent, unit>
actorApi : IActor
cb : 'TDataEvent -> unit
Returns: IKillSwitch

subscribeCmdWithFilter source actorApi filter take cb

Full Usage: subscribeCmdWithFilter source actorApi filter take cb

Parameters:
    source : Source<'TDataEvent, unit>
    actorApi : IActor
    filter : 'TDataEvent -> bool
    take : int64
    cb : 'TDataEvent -> unit

Returns: IKillSwitch * Async<unit>
source : Source<'TDataEvent, unit>
actorApi : IActor
filter : 'TDataEvent -> bool
take : int64
cb : 'TDataEvent -> unit
Returns: IKillSwitch * Async<unit>

subscribeToStream source mat sink

Full Usage: subscribeToStream source mat sink

Parameters:
Returns: UniqueKillSwitch * 'b
source : Source<'TDataEvent, 'a>
mat : IMaterializer
sink : Sink<'TDataEvent, 'b>
Returns: UniqueKillSwitch * 'b

Type something to start searching.