Class JournalSpec

Inheritance

JournalSpec

Implements

IActorRefFactory

IDisposable

Inherited Members

PluginSpec.ActorInstanceId

PluginSpec.FromConfig(Config)

PluginSpec.Extension

PluginSpec.Pid

PluginSpec.WriterGuid

PluginSpec.Subscribe<T>(IActorRef)

TestKit.Output

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.Sys

TestKitBase.TestKitSettings

TestKitBase.LastSender

TestKitBase.Now

TestKitBase.Log

TestKitBase.LastMessage

TestKitBase.TestActor

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.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.Journal

Assembly: Akka.Persistence.TCK.dll

Syntax

public abstract class JournalSpec : PluginSpec, IActorRefFactory, IDisposable

Constructors

| Edit this page View Source

JournalSpec(ActorSystem, ITestOutputHelper)

Declaration

protected JournalSpec(ActorSystem system = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
ActorSystem	system
ITestOutputHelper	output

| Edit this page View Source

JournalSpec(ActorSystemSetup, string, ITestOutputHelper)

Declaration

protected JournalSpec(ActorSystemSetup setup, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
ActorSystemSetup	setup
string	actorSystemName
ITestOutputHelper	output

| Edit this page View Source

JournalSpec(Config, string, ITestOutputHelper)

Declaration

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

Parameters

Type	Name	Description
Config	config
string	actorSystemName
ITestOutputHelper	output

| Edit this page View Source

JournalSpec(Type, string, ITestOutputHelper)

Declaration

protected JournalSpec(Type journalType, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
Type	journalType
string	actorSystemName
ITestOutputHelper	output

Fields

| Edit this page View Source

Config

Declaration

protected static readonly Config Config

Field Value

Type	Description
Config

Properties

| Edit this page View Source

Journal

Declaration

protected IActorRef Journal { get; }

Property Value

Type	Description
IActorRef

| Edit this page View Source

SupportsAtomicPersistAllOfSeveralEvents

Implementation may override and return false if it does not support atomic writes of several events, as emitted by PersistAll<TEvent>(IEnumerable<TEvent>, Action<TEvent>).

Declaration

protected virtual bool SupportsAtomicPersistAllOfSeveralEvents { get; }

Property Value

Type	Description
bool

| Edit this page View Source

SupportsRejectingNonSerializableObjects

When true enables tests which check if the Journal properly rejects writes of objects which are not serializable.

Declaration

protected virtual bool SupportsRejectingNonSerializableObjects { get; }

Property Value

Type	Description
bool

| Edit this page View Source

SupportsSerialization

When enabled, allows serialization specs to run.

Declaration

protected override bool SupportsSerialization { get; }

Property Value

Type	Description
bool

Overrides

PluginSpec.SupportsSerialization

Methods

| Edit this page View Source

Initialize()

Initializes a journal with set o predefined messages.

Declaration

protected IEnumerable<AtomicWrite> Initialize()

Returns

Type	Description
IEnumerable<AtomicWrite>

| Edit this page View Source

IsReplayedMessage(ReplayedMessage, long, bool)

Declaration

protected bool IsReplayedMessage(ReplayedMessage message, long seqNr, bool isDeleted = false)

Parameters

Type	Name	Description
ReplayedMessage	message
long	seqNr
bool	isDeleted

Returns

Type	Description
bool

| Edit this page View Source

Journal_optionally_may_reject_non_serializable_events()

Declaration

[Fact]
public virtual void Journal_optionally_may_reject_non_serializable_events()

| Edit this page View Source

Journal_should_not_replay_messages_if_count_limit_equals_zero()

Declaration

[Fact]
public virtual void Journal_should_not_replay_messages_if_count_limit_equals_zero()

| Edit this page View Source

Journal_should_not_replay_messages_if_lower_sequence_number_bound_is_greater_than_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_not_replay_messages_if_lower_sequence_number_bound_is_greater_than_upper_sequence_number_bound()

| Edit this page View Source

Journal_should_not_replay_messages_if_the_persistent_actor_has_not_yet_written_messages()

Declaration

[Fact]
public virtual void Journal_should_not_replay_messages_if_the_persistent_actor_has_not_yet_written_messages()

| Edit this page View Source

Journal_should_not_replay_permanently_deleted_messages_on_range_deletion()

Declaration

[Fact]
public virtual void Journal_should_not_replay_permanently_deleted_messages_on_range_deletion()

| Edit this page View Source

Journal_should_not_reset_HighestSequenceNr_after_journal_cleanup()

Declaration

[Fact]
public virtual void Journal_should_not_reset_HighestSequenceNr_after_journal_cleanup()

| Edit this page View Source

Journal_should_not_reset_HighestSequenceNr_after_message_deletion()

Declaration

[Fact]
public virtual void Journal_should_not_reset_HighestSequenceNr_after_message_deletion()

| Edit this page View Source

Journal_should_replay_a_single_if_lower_sequence_number_bound_equals_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_a_single_if_lower_sequence_number_bound_equals_upper_sequence_number_bound()

| Edit this page View Source

Journal_should_replay_a_single_message_if_count_limit_is_equal_one()

Declaration

[Fact]
public virtual void Journal_should_replay_a_single_message_if_count_limit_is_equal_one()

| Edit this page View Source

Journal_should_replay_all_messages()

Declaration

[Fact]
public virtual void Journal_should_replay_all_messages()

| Edit this page View Source

Journal_should_replay_messages_using_a_count_limit()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_a_count_limit()

| Edit this page View Source

Journal_should_replay_messages_using_a_lower_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_a_lower_sequence_number_bound()

| Edit this page View Source

Journal_should_replay_messages_using_an_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_an_upper_sequence_number_bound()

| Edit this page View Source

Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound()

| Edit this page View Source

Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound_and_count_limit()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound_and_count_limit()

| Edit this page View Source

Journal_should_serialize_events()

Declaration

[Fact]
public virtual void Journal_should_serialize_events()

| Edit this page View Source

PreparePersistenceId(string)

Overridable hook that is called before populating the journal for the next test case. pid is the persistenceId that will be used in the test. This method may be needed to clean pre-existing events from the log.

Declaration

protected virtual void PreparePersistenceId(string pid)

Parameters

Type	Name	Description
string	pid

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)