Class ChainSetup<TIn, TOut, TMat>

Inheritance
Object
ChainSetup<TIn, TOut, TMat>
Inherited Members
Namespace: Akka.Streams.TestKit
Assembly: Akka.Streams.TestKit.dll
Syntax
public class ChainSetup<TIn, TOut, TMat>
Type Parameters
Name Description
TIn
TOut
TMat

Constructors

| Improve this Doc View Source

ChainSetup(Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>>, ActorMaterializerSettings, ActorMaterializer, Func<Source<TOut, NotUsed>, ActorMaterializer, IPublisher<TOut>>, TestKitBase)

Declaration
public ChainSetup(Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>> stream, ActorMaterializerSettings settings, ActorMaterializer materializer, Func<Source<TOut, NotUsed>, ActorMaterializer, IPublisher<TOut>> toPublisher, TestKitBase system)
Parameters
Type Name Description
Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>> stream
ActorMaterializerSettings settings
ActorMaterializer materializer
Func<Source<TOut, NotUsed>, ActorMaterializer, Reactive.Streams.IPublisher<TOut>> toPublisher
TestKitBase system
| Improve this Doc View Source

ChainSetup(Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>>, ActorMaterializerSettings, Func<ActorMaterializerSettings, IActorRefFactory, ActorMaterializer>, Func<Source<TOut, NotUsed>, ActorMaterializer, IPublisher<TOut>>, TestKitBase)

Declaration
public ChainSetup(Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>> stream, ActorMaterializerSettings settings, Func<ActorMaterializerSettings, IActorRefFactory, ActorMaterializer> materializerCreator, Func<Source<TOut, NotUsed>, ActorMaterializer, IPublisher<TOut>> toPublisher, TestKitBase system)
Parameters
Type Name Description
Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>> stream
ActorMaterializerSettings settings
Func<ActorMaterializerSettings, IActorRefFactory, ActorMaterializer> materializerCreator
Func<Source<TOut, NotUsed>, ActorMaterializer, Reactive.Streams.IPublisher<TOut>> toPublisher
TestKitBase system
| Improve this Doc View Source

ChainSetup(Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>>, ActorMaterializerSettings, Func<Source<TOut, NotUsed>, ActorMaterializer, IPublisher<TOut>>, TestKitBase)

Declaration
public ChainSetup(Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>> stream, ActorMaterializerSettings settings, Func<Source<TOut, NotUsed>, ActorMaterializer, IPublisher<TOut>> toPublisher, TestKitBase system)
Parameters
Type Name Description
Func<Flow<TIn, TIn, NotUsed>, Flow<TIn, TOut, TMat>> stream
ActorMaterializerSettings settings
Func<Source<TOut, NotUsed>, ActorMaterializer, Reactive.Streams.IPublisher<TOut>> toPublisher
TestKitBase system

Fields

| Improve this Doc View Source

System

Declaration
protected readonly TestKitBase System
Field Value
Type Description
TestKitBase

Properties

| Improve this Doc View Source

Downstream

Declaration
public TestSubscriber.ManualProbe<TOut> Downstream { get; }
Property Value
Type Description
TestSubscriber.ManualProbe<TOut>
| Improve this Doc View Source

DownstreamSubscription

Declaration
public ISubscription DownstreamSubscription { get; }
Property Value
Type Description
Reactive.Streams.ISubscription
| Improve this Doc View Source

Initialized

Declaration
public bool Initialized { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

Materializer

Declaration
public ActorMaterializer Materializer { get; }
Property Value
Type Description
ActorMaterializer
| Improve this Doc View Source

Publisher

Declaration
public IPublisher<TOut> Publisher { get; }
Property Value
Type Description
Reactive.Streams.IPublisher<TOut>
| Improve this Doc View Source

Settings

Declaration
public ActorMaterializerSettings Settings { get; }
Property Value
Type Description
ActorMaterializerSettings
| Improve this Doc View Source

Upstream

Declaration
public TestPublisher.ManualProbe<TIn> Upstream { get; }
Property Value
Type Description
TestPublisher.ManualProbe<TIn>
| Improve this Doc View Source

UpstreamSubscription

Declaration
public StreamTestKit.PublisherProbeSubscription<TIn> UpstreamSubscription { get; }
Property Value
Type Description
StreamTestKit.PublisherProbeSubscription<TIn>

Methods

| Improve this Doc View Source

EnsureInitialized()

Declaration
protected virtual void EnsureInitialized()
| Improve this Doc View Source

InitializeAsync()

Declaration
public virtual async Task<ChainSetup<TIn, TOut, TMat>> InitializeAsync()
Returns
Type Description
Task<ChainSetup<TIn, TOut, TMat>>

Extension Methods