Search Results for

    Show / Hide Table of Contents

    Class SnapshotStoreSpec

    This spec aims to verify custom SnapshotStore implementations. Every custom authors snapshot store spec should have it's spec suite included.

    Inheritance
    object
    TestKitBase
    TestKit
    PluginSpec
    SnapshotStoreSpec
    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.Snapshot
    Assembly: Akka.Persistence.TCK.dll
    Syntax
    public abstract class SnapshotStoreSpec : PluginSpec, IActorRefFactory, IDisposable

    Constructors

    | Edit this page View Source

    SnapshotStoreSpec(ActorSystem, ITestOutputHelper)

    Declaration
    protected SnapshotStoreSpec(ActorSystem system = null, ITestOutputHelper output = null)
    Parameters
    Type Name Description
    ActorSystem system
    ITestOutputHelper output
    | Edit this page View Source

    SnapshotStoreSpec(ActorSystemSetup, string, ITestOutputHelper)

    Declaration
    protected SnapshotStoreSpec(ActorSystemSetup setup, string actorSystemName = null, ITestOutputHelper output = null)
    Parameters
    Type Name Description
    ActorSystemSetup setup
    string actorSystemName
    ITestOutputHelper output
    | Edit this page View Source

    SnapshotStoreSpec(Config, string, ITestOutputHelper)

    Declaration
    protected SnapshotStoreSpec(Config config = null, string actorSystemName = null, ITestOutputHelper output = null)
    Parameters
    Type Name Description
    Config config
    string actorSystemName
    ITestOutputHelper output
    | Edit this page View Source

    SnapshotStoreSpec(Type, string)

    Declaration
    protected SnapshotStoreSpec(Type snapshotStoreType, string actorSystemName = null)
    Parameters
    Type Name Description
    Type snapshotStoreType
    string actorSystemName

    Fields

    | Edit this page View Source

    Config

    Declaration
    protected static readonly Config Config
    Field Value
    Type Description
    Config
    | Edit this page View Source

    Metadata

    Declaration
    protected List<SnapshotMetadata> Metadata
    Field Value
    Type Description
    List<SnapshotMetadata>

    Properties

    | Edit this page View Source

    SnapshotByteSizeLimit

    The limit defines a number of bytes persistence plugin can support to store the snapshot. If plugin does not support persistence of the snapshots of 10000 bytes or may support more than default size, the value can be overriden by the SnapshotStoreSpec implementation with a note in a plugin documentation.

    Declaration
    protected virtual int SnapshotByteSizeLimit { get; }
    Property Value
    Type Description
    int
    | Edit this page View Source

    SnapshotStore

    Declaration
    protected IActorRef SnapshotStore { get; }
    Property Value
    Type Description
    IActorRef
    | 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 snapshot store with set of predefined snapshots.

    Declaration
    protected IEnumerable<SnapshotMetadata> Initialize()
    Returns
    Type Description
    IEnumerable<SnapshotMetadata>
    | Edit this page View Source

    ShouldSerializeSnapshots()

    Declaration
    [Fact]
    public virtual void ShouldSerializeSnapshots()
    | Edit this page View Source

    SnapshotStore_should_delete_a_single_snapshot_identified_by_SequenceNr_in_snapshot_metadata()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_delete_a_single_snapshot_identified_by_SequenceNr_in_snapshot_metadata()
    | Edit this page View Source

    SnapshotStore_should_delete_a_single_snapshot_identified_by_SequenceNr_in_snapshot_metadata_if_timestamp_is_MinValue()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_delete_a_single_snapshot_identified_by_SequenceNr_in_snapshot_metadata_if_timestamp_is_MinValue()
    | Edit this page View Source

    SnapshotStore_should_delete_all_snapshots_matching_upper_sequence_number_and_timestamp_bounds()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_delete_all_snapshots_matching_upper_sequence_number_and_timestamp_bounds()
    | Edit this page View Source

    SnapshotStore_should_load_the_most_recent_snapshot()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_load_the_most_recent_snapshot()
    | Edit this page View Source

    SnapshotStore_should_load_the_most_recent_snapshot_matching_an_upper_sequence_number_and_timestamp_bound()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_load_the_most_recent_snapshot_matching_an_upper_sequence_number_and_timestamp_bound()
    | Edit this page View Source

    SnapshotStore_should_load_the_most_recent_snapshot_matching_an_upper_sequence_number_bound()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_load_the_most_recent_snapshot_matching_an_upper_sequence_number_bound()
    | Edit this page View Source

    SnapshotStore_should_not_delete_snapshot_identified_by_SequenceNr_if_metadata_timestamp_is_less_than_stored_timestamp()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_not_delete_snapshot_identified_by_SequenceNr_if_metadata_timestamp_is_less_than_stored_timestamp()
    | Edit this page View Source

    SnapshotStore_should_not_delete_snapshots_with_non_matching_upper_timestamp_bounds()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_not_delete_snapshots_with_non_matching_upper_timestamp_bounds()
    | Edit this page View Source

    SnapshotStore_should_not_load_a_snapshot_given_an_invalid_persistence_id()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_not_load_a_snapshot_given_an_invalid_persistence_id()
    | Edit this page View Source

    SnapshotStore_should_not_load_a_snapshot_given_non_matching_sequence_number_criteria()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_not_load_a_snapshot_given_non_matching_sequence_number_criteria()
    | Edit this page View Source

    SnapshotStore_should_not_load_a_snapshot_given_non_matching_timestamp_criteria()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_not_load_a_snapshot_given_non_matching_timestamp_criteria()
    | Edit this page View Source

    SnapshotStore_should_save_and_overwrite_snapshot_with_same_sequence_number()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_save_and_overwrite_snapshot_with_same_sequence_number()
    | Edit this page View Source

    SnapshotStore_should_save_bigger_size_snapshot()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_save_bigger_size_snapshot()

    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)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET