| IJournalQueryExecutorSelectByPersistenceIdAsync Method |
Asynchronously replays a callback on all selected events for provided
persistenceId, within boundaries of fromSequenceNr
and toSequenceNr up to max number of events.
Namespace:
Akka.Persistence.Sql.Common.Journal
Assembly:
Akka.Persistence.Sql.Common (in Akka.Persistence.Sql.Common.dll) Version: 1.0.0.0 (1.0.0.0)
Syntax Task SelectByPersistenceIdAsync(
DbConnection connection,
CancellationToken cancellationToken,
string persistenceId,
long fromSequenceNr,
long toSequenceNr,
long max,
Action<IPersistentRepresentation> callback
)
abstract SelectByPersistenceIdAsync :
connection : DbConnection *
cancellationToken : CancellationToken *
persistenceId : string *
fromSequenceNr : int64 *
toSequenceNr : int64 *
max : int64 *
callback : Action<IPersistentRepresentation> -> Task
Parameters
- connection
- Type: System.Data.CommonDbConnection
TBD - cancellationToken
- Type: System.ThreadingCancellationToken
TBD - persistenceId
- Type: SystemString
TBD - fromSequenceNr
- Type: SystemInt64
TBD - toSequenceNr
- Type: SystemInt64
TBD - max
- Type: SystemInt64
TBD - callback
- Type: SystemActionIPersistentRepresentation
TBD
Return Value
Type:
TaskTBD
See Also