Class CurrentEventsByTagSpec

Inheritance

object

TestKitBase

TestKit

CurrentEventsByTagSpec

Implements

IActorRefFactory

IDisposable

Inherited Members

TestKit.Output

TestKit.Sys

TestKit.TestActor

TestKit.DefaultConfig

TestKit.FullDebugConfig

TestKit.Assertions

TestKit.AfterAll()

TestKit.InitializeLogger(ActorSystem)

TestKit.InitializeLogger(ActorSystem, string)

TestKit.Dispose(bool)

TestKit.Dispose()

TestKitBase.InitializeTest(ActorSystem, ActorSystemSetup, string, string)

TestKitBase.InitializeTest(ActorSystem, Config, string, string)

TestKitBase.TestKitSettings

TestKitBase.LastSender

TestKitBase.Now

TestKitBase.Log

TestKitBase.LastMessage

TestKitBase.EventFilter

TestKitBase.CreateEventFilter(ActorSystem)

TestKitBase.HasMessages

TestKitBase.IgnoreMessages(Func<object, bool>)

TestKitBase.IgnoreMessages<TMsg>(Func<TMsg, bool>)

TestKitBase.IgnoreMessages<TMsg>()

TestKitBase.IgnoreNoMessages()

TestKitBase.Watch(IActorRef)

TestKitBase.WatchAsync(IActorRef)

TestKitBase.Unwatch(IActorRef)

TestKitBase.UnwatchAsync(IActorRef)

TestKitBase.SetAutoPilot(AutoPilot)

TestKitBase.RemainingOrDefault

TestKitBase.NoMessageRemainingOrDefault

TestKitBase.Remaining

TestKitBase.RemainingOr(TimeSpan)

TestKitBase.RemainingOrDilated(TimeSpan?)

TestKitBase.Dilated(TimeSpan)

TestKitBase.GetTimeoutOrDefault(TimeSpan?)

TestKitBase.Shutdown(TimeSpan?, bool)

TestKitBase.Shutdown(ActorSystem, TimeSpan?, bool)

TestKitBase.ChildActorOf(Props, string, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, string, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOf(Props, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOf(Props, string, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, string, CancellationToken)

TestKitBase.ChildActorOf(Props, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, CancellationToken)

TestKitBase.CreateTestActor(string)

TestKitBase.CreateTestProbe(string)

TestKitBase.CreateTestProbe(ActorSystem, string)

TestKitBase.CreateTestLatch(int)

TestKitBase.CreateTestBarrier(int)

TestKitBase.ActorOf(Props)

TestKitBase.ActorOf(Props, string)

TestKitBase.ActorOf<TActor>()

TestKitBase.ActorOf<TActor>(string)

TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>)

TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>, string)

TestKitBase.ActorOf(Action<IActorDsl, IActorContext>, string)

TestKitBase.ActorOf(Action<IActorDsl>, string)

TestKitBase.ActorSelection(ActorPath)

TestKitBase.ActorSelection(string)

TestKitBase.ActorSelection(IActorRef, string)

TestKitBase.ActorOfAsTestActorRef<TActor>(Props, IActorRef, string)

TestKitBase.ActorOfAsTestActorRef<TActor>(Props, string)

TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, IActorRef, string)

TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, string)

TestKitBase.ActorOfAsTestActorRef<TActor>(IActorRef, string)

TestKitBase.ActorOfAsTestActorRef<TActor>(string)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, IActorRef, string, bool)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, string, bool)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(IActorRef, string, bool)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(string, bool)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, IActorRef, string, bool)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, string, bool)

TestKitBase.AwaitAssert(Action, TimeSpan?, TimeSpan?, CancellationToken)

TestKitBase.AwaitAssertAsync(Action, TimeSpan?, TimeSpan?, CancellationToken)

TestKitBase.AwaitAssertAsync(Func<Task>, TimeSpan?, TimeSpan?, CancellationToken)

TestKitBase.AwaitCondition(Func<bool>, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<bool>>, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<bool>, CancellationToken)

TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, CancellationToken)

TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, string, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, string, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<bool>, TimeSpan?, string, CancellationToken)

TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, TimeSpan?, string, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, TimeSpan?, string, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<bool>, TimeSpan?, TimeSpan?, string, CancellationToken)

TestKitBase.AwaitConditionNoThrow(Func<bool>, TimeSpan, TimeSpan?, CancellationToken)

TestKitBase.AwaitConditionNoThrowAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, CancellationToken)

TestKitBase.AwaitConditionNoThrowAsync(Func<bool>, TimeSpan, TimeSpan?, CancellationToken)

TestKitBase.InternalAwaitCondition(Func<bool>, TimeSpan, TimeSpan?, Action<string, object[]>, CancellationToken)

TestKitBase.InternalAwaitConditionAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, Action<string, object[]>, CancellationToken)

TestKitBase.InternalAwaitCondition(Func<bool>, TimeSpan, TimeSpan?, Action<string, object[]>, ILoggingAdapter, CancellationToken)

TestKitBase.InternalAwaitConditionAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, Action<string, object[]>, ILoggingAdapter, CancellationToken)

TestKitBase.ExpectMsg<T>(TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsg<T>(T, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(T, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsg<T>(Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsg<T>(Action<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Action<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsg<T>(Func<T, IActorRef, bool>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Func<T, IActorRef, bool>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsg<T>(Action<T, IActorRef>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Action<T, IActorRef>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsg<T>(T, Func<T, T, bool>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(T, Func<T, T, bool>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectTerminated(IActorRef, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectTerminatedAsync(IActorRef, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectNoMsg(CancellationToken)

TestKitBase.ExpectNoMsgAsync(CancellationToken)

TestKitBase.ExpectNoMsg(TimeSpan, CancellationToken)

TestKitBase.ExpectNoMsgAsync(TimeSpan, CancellationToken)

TestKitBase.ExpectNoMsg(int, CancellationToken)

TestKitBase.ExpectNoMsgAsync(int, CancellationToken)

TestKitBase.ExpectMsgAnyOf<T>(IEnumerable<T>, CancellationToken)

TestKitBase.ExpectMsgAnyOfAsync<T>(IEnumerable<T>, CancellationToken)

TestKitBase.ExpectMsgAllOf<T>(params T[])

TestKitBase.ExpectMsgAllOf<T>(IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOfAsync<T>(IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOf<T>(TimeSpan, params T[])

TestKitBase.ExpectMsgAllOf<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOfAsync<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicates(params PredicateInfo[])

TestKitBase.ExpectMsgAllOfMatchingPredicates(IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, params PredicateInfo[])

TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, T, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, T, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(Predicate<IActorRef>, Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(Predicate<IActorRef>, Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, Action<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Action<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(Action<IActorRef>, Action<T>, TimeSpan?, string, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(Action<IActorRef>, Action<T>, TimeSpan?, string, CancellationToken)

TestKitBase.FishForMessage(Predicate<object>, TimeSpan?, string, CancellationToken)

TestKitBase.FishForMessageAsync(Predicate<object>, TimeSpan?, string, CancellationToken)

TestKitBase.FishForMessage<T>(Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.FishForMessageAsync<T>(Predicate<T>, TimeSpan?, string, CancellationToken)

TestKitBase.FishForMessage<T>(Predicate<T>, ArrayList, TimeSpan?, string, CancellationToken)

TestKitBase.FishForMessageAsync<T>(Predicate<T>, ArrayList, TimeSpan?, string, CancellationToken)

TestKitBase.FishUntilMessageAsync<T>(TimeSpan?, CancellationToken)

TestKitBase.WaitForRadioSilenceAsync(TimeSpan?, uint?, CancellationToken)

TestKitBase.ReceiveOne(TimeSpan?, CancellationToken)

TestKitBase.ReceiveOneAsync(TimeSpan?, CancellationToken)

TestKitBase.TryReceiveOne(out MessageEnvelope, TimeSpan?, CancellationToken)

TestKitBase.TryReceiveOneAsync(TimeSpan?, CancellationToken)

TestKitBase.PeekOne(TimeSpan?, CancellationToken)

TestKitBase.PeekOneAsync(TimeSpan?, CancellationToken)

TestKitBase.PeekOne(CancellationToken)

TestKitBase.PeekOneAsync(CancellationToken)

TestKitBase.TryPeekOne(out MessageEnvelope, TimeSpan?, CancellationToken)

TestKitBase.TryPeekOneAsync(TimeSpan?, CancellationToken)

TestKitBase.ReceiveWhile<T>(TimeSpan?, Func<object, T>, int, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(TimeSpan?, Func<object, T>, int, CancellationToken)

TestKitBase.ReceiveWhile<T>(TimeSpan?, TimeSpan?, Func<object, T>, int, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(TimeSpan?, TimeSpan?, Func<object, T>, int, CancellationToken)

TestKitBase.ReceiveWhile<T>(Func<object, T>, TimeSpan?, TimeSpan?, int, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(Func<object, T>, TimeSpan?, TimeSpan?, int, CancellationToken)

TestKitBase.ReceiveWhile<T>(Predicate<T>, TimeSpan?, TimeSpan?, int, bool, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(Predicate<T>, TimeSpan?, TimeSpan?, int, bool, CancellationToken)

TestKitBase.ReceiveN(int, CancellationToken)

TestKitBase.ReceiveNAsync(int, CancellationToken)

TestKitBase.ReceiveN(int, TimeSpan, CancellationToken)

TestKitBase.ReceiveNAsync(int, TimeSpan, CancellationToken)

TestKitBase.Within(TimeSpan, Action, TimeSpan?, CancellationToken)

TestKitBase.WithinAsync(TimeSpan, Func<Task>, TimeSpan?, CancellationToken)

TestKitBase.Within(TimeSpan, TimeSpan, Action, string, TimeSpan?, CancellationToken)

TestKitBase.WithinAsync(TimeSpan, TimeSpan, Func<Task>, string, TimeSpan?, CancellationToken)

TestKitBase.Within<T>(TimeSpan, Func<T>, TimeSpan?, CancellationToken)

TestKitBase.WithinAsync<T>(TimeSpan, Func<Task<T>>, TimeSpan?, CancellationToken)

TestKitBase.Within<T>(TimeSpan, TimeSpan, Func<T>, string, TimeSpan?, CancellationToken)

TestKitBase.WithinAsync<T>(TimeSpan, TimeSpan, Func<Task<T>>, string, TimeSpan?, CancellationToken)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Persistence.TCK.Query

Assembly: Akka.Persistence.TCK.dll

Syntax

public abstract class CurrentEventsByTagSpec : TestKit, IActorRefFactory, IDisposable

Constructors

CurrentEventsByTagSpec(Config, string, ITestOutputHelper)

Declaration

protected CurrentEventsByTagSpec(Config config = null, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
Config	config
string	actorSystemName
ITestOutputHelper	output

CurrentEventsByTagSpec(Config, string, ITestOutputHelper)

Declaration

protected CurrentEventsByTagSpec(Config config = null, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
Config	config
string	actorSystemName
ITestOutputHelper	output

Properties

Materializer

Declaration

protected ActorMaterializer Materializer { get; }

Property Value

Type	Description
ActorMaterializer

ReadJournal

Declaration

protected IReadJournal ReadJournal { get; set; }

Property Value

Type	Description
IReadJournal

SupportsTagsInEventEnvelope

Declaration

protected virtual bool SupportsTagsInEventEnvelope { get; }

Property Value

Type	Description
bool

Methods

ReadJournal_query_CurrentEventsByTag_should_complete_when_no_events()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 91)]
public virtual void ReadJournal_query_CurrentEventsByTag_should_complete_when_no_events()

ReadJournal_query_CurrentEventsByTag_should_find_events_from_offset_exclusive()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 156)]
public virtual void ReadJournal_query_CurrentEventsByTag_should_find_events_from_offset_exclusive()

ReadJournal_query_CurrentEventsByTag_should_find_existing_events()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 43)]
public virtual void ReadJournal_query_CurrentEventsByTag_should_find_existing_events()

ReadJournal_query_CurrentEventsByTag_should_include_timestamp_in_EventEnvelope()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 226)]
public virtual void ReadJournal_query_CurrentEventsByTag_should_include_timestamp_in_EventEnvelope()

ReadJournal_query_CurrentEventsByTag_should_not_see_new_events_after_complete()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 114)]
public virtual void ReadJournal_query_CurrentEventsByTag_should_not_see_new_events_after_complete()

ReadJournal_query_CurrentEventsByTag_should_see_all_150_events()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 198)]
public virtual void ReadJournal_query_CurrentEventsByTag_should_see_all_150_events()

ReadJournal_should_implement_ICurrentEventsByTagQuery()

Declaration

[Fact("D:\\a\\1\\s\\src\\core\\Akka.Persistence.TCK\\Query\\CurrentEventsByTagSpec.cs", 37)]
public void ReadJournal_should_implement_ICurrentEventsByTagQuery()

Implements

IActorRefFactory

IDisposable

Extension Methods

ActorRefFactoryExtensions.ActorOf<TActor>(IActorRefFactory, string)

ActorRefFactoryExtensions.ActorSelection(IActorRefFactory, IActorRef, string)

ActExtensions.ActorOf(IActorRefFactory, Action<IActorDsl, IActorContext>, string?)

ActExtensions.ActorOf(IActorRefFactory, Action<IActorDsl>, string?)

ActorMaterializerExtensions.Materializer(IActorRefFactory, ActorMaterializerSettings, string)

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

TestPublisher.CreateManualPublisherProbe<T>(TestKitBase, bool)

TestPublisher.CreatePublisherProbe<T>(TestKitBase, long)

TestSink.SinkProbe<T>(TestKitBase)

TestSource.SourceProbe<T>(TestKitBase)

TestSubscriber.CreateManualSubscriberProbe<T>(TestKitBase)

TestSubscriber.CreateSubscriberProbe<T>(TestKitBase)

Utils.AssertAllStagesStopped(TestKitBase, Action, IMaterializer, TimeSpan?, CancellationToken)

Utils.AssertAllStagesStoppedAsync(TestKitBase, Func<Task>, IMaterializer, TimeSpan?, CancellationToken)

Utils.AssertAllStagesStoppedAsync<T>(TestKitBase, Func<Task<T>>, IMaterializer, TimeSpan?, CancellationToken)

Utils.AssertAllStagesStopped<T>(TestKitBase, Func<T>, IMaterializer, TimeSpan?, CancellationToken)

Extensions.AsInstanceOf<T>(object)