Class JournalInterceptors.OnCondition

Inheritance
object
JournalInterceptors.OnCondition
Implements
Inherited Members
Namespace: Akka.Persistence.TestKit
Assembly: Akka.Persistence.TestKit.dll
Syntax
public sealed class JournalInterceptors.OnCondition : IJournalInterceptor

Constructors

| Edit this page View Source

OnCondition(Func<IPersistentRepresentation, bool>, IJournalInterceptor, bool)

Declaration
public OnCondition(Func<IPersistentRepresentation, bool> predicate, IJournalInterceptor next, bool negate = false)
Parameters
Type Name Description
Func<IPersistentRepresentation, bool> predicate
IJournalInterceptor next
bool negate
| Edit this page View Source

OnCondition(Func<IPersistentRepresentation, Task<bool>>, IJournalInterceptor, bool)

Declaration
public OnCondition(Func<IPersistentRepresentation, Task<bool>> predicate, IJournalInterceptor next, bool negate = false)
Parameters
Type Name Description
Func<IPersistentRepresentation, Task<bool>> predicate
IJournalInterceptor next
bool negate

Methods

| Edit this page View Source

InterceptAsync(IPersistentRepresentation)

Method will be called for each individual message before it is written or recovered.

Declaration
public Task InterceptAsync(IPersistentRepresentation message)
Parameters
Type Name Description
IPersistentRepresentation message

Written or recovered message.
Returns
Type Description
Task

Implements

Extension Methods