Class JournalInterceptors.CancelableDelay

Inheritance

object

JournalInterceptors.CancelableDelay

Implements

IJournalInterceptor

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Persistence.TestKit

Assembly: Akka.Persistence.TestKit.dll

Syntax

public sealed class JournalInterceptors.CancelableDelay : IJournalInterceptor

Constructors

CancelableDelay(TimeSpan, IJournalInterceptor, CancellationToken)

Declaration

public CancelableDelay(TimeSpan delay, IJournalInterceptor next, CancellationToken cancellationToken)

Parameters

Type	Name	Description
TimeSpan	delay
IJournalInterceptor	next
CancellationToken	cancellationToken

Methods

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

IJournalInterceptor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)