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

| Edit this page 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, IPublisher<TOut>> toPublisher
TestKitBase system
| Edit this page 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, IPublisher<TOut>> toPublisher
TestKitBase system
| Edit this page 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, IPublisher<TOut>> toPublisher
TestKitBase system

Fields

| Edit this page View Source

System

Declaration
protected readonly TestKitBase System
Field Value
Type Description
TestKitBase

Properties

| Edit this page View Source

Downstream

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

DownstreamSubscription

Declaration
public ISubscription DownstreamSubscription { get; }
Property Value
Type Description
ISubscription
| Edit this page View Source

Initialized

Declaration
public bool Initialized { get; }
Property Value
Type Description
bool
| Edit this page View Source

Materializer

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

Publisher

Declaration
public IPublisher<TOut> Publisher { get; }
Property Value
Type Description
IPublisher<TOut>
| Edit this page View Source

Settings

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

Upstream

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

UpstreamSubscription

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

Methods

| Edit this page View Source

EnsureInitialized()

Declaration
protected virtual void EnsureInitialized()
| Edit this page View Source

InitializeAsync()

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

Extension Methods