Internal Module
Functions and values
Function or value | Description |
|
|
|
|
Full Usage:
subscribeCmdWithFilter source actorApi filter take cb
Parameters:
Source<'TDataEvent, unit>
actorApi : IActor
filter : 'TDataEvent -> bool
take : int64
cb : 'TDataEvent -> unit
Returns: IKillSwitch * Async<unit>
|
|
Full Usage:
subscribeToStream source mat sink
Parameters:
Source<'TDataEvent, 'a>
mat : IMaterializer
sink : Sink<'TDataEvent, 'b>
Returns: UniqueKillSwitch * 'b
|
|