akka.stream

Class ActorMaterializerSettings$

java.lang.Object

akka.stream.ActorMaterializerSettings$

public class ActorMaterializerSettings$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static ActorMaterializerSettings$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
ActorMaterializerSettings$()

Method Summary

Modifier and Type	Method and Description
ActorMaterializerSettings	apply(ActorSystem system) Create ActorMaterializerSettings from the settings of an ActorSystem (Scala).
ActorMaterializerSettings	apply(com.typesafe.config.Config config) Create ActorMaterializerSettings from a Config subsection (Scala).
ActorMaterializerSettings	apply(int initialInputBufferSize, int maxInputBufferSize, java.lang.String dispatcher, scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider, StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings, boolean debugLogging, int outputBurstLimit, boolean fuzzingMode, boolean autoFusing, int maxFixedBufferSize) Create ActorMaterializerSettings from individual settings (Scala).
ActorMaterializerSettings	create(ActorSystem system) Create ActorMaterializerSettings from the settings of an ActorSystem (Java).
ActorMaterializerSettings	create(com.typesafe.config.Config config) Create ActorMaterializerSettings from a Config subsection (Java).
ActorMaterializerSettings	create(int initialInputBufferSize, int maxInputBufferSize, java.lang.String dispatcher, scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider, StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings, boolean debugLogging, int outputBurstLimit, boolean fuzzingMode, boolean autoFusing, int maxFixedBufferSize) Create ActorMaterializerSettings from individual settings (Java).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final ActorMaterializerSettings$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ActorMaterializerSettings$

public ActorMaterializerSettings$()

Method Detail

apply

public ActorMaterializerSettings apply(int initialInputBufferSize,
                                       int maxInputBufferSize,
                                       java.lang.String dispatcher,
                                       scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider,
                                       StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings,
                                       boolean debugLogging,
                                       int outputBurstLimit,
                                       boolean fuzzingMode,
                                       boolean autoFusing,
                                       int maxFixedBufferSize)

Create ActorMaterializerSettings from individual settings (Scala).

Parameters:

initialInputBufferSize - (undocumented)

maxInputBufferSize - (undocumented)

dispatcher - (undocumented)

supervisionDecider - (undocumented)

subscriptionTimeoutSettings - (undocumented)

debugLogging - (undocumented)

outputBurstLimit - (undocumented)

fuzzingMode - (undocumented)

autoFusing - (undocumented)

maxFixedBufferSize - (undocumented)

Returns:

(undocumented)

apply

public ActorMaterializerSettings apply(ActorSystem system)

Create ActorMaterializerSettings from the settings of an ActorSystem (Scala).

Parameters:

system - (undocumented)

Returns:

(undocumented)

apply

public ActorMaterializerSettings apply(com.typesafe.config.Config config)

Create ActorMaterializerSettings from a Config subsection (Scala).

Parameters:

config - (undocumented)

Returns:

(undocumented)

create

public ActorMaterializerSettings create(int initialInputBufferSize,
                                        int maxInputBufferSize,
                                        java.lang.String dispatcher,
                                        scala.Function1<java.lang.Throwable,Supervision.Directive> supervisionDecider,
                                        StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings,
                                        boolean debugLogging,
                                        int outputBurstLimit,
                                        boolean fuzzingMode,
                                        boolean autoFusing,
                                        int maxFixedBufferSize)

Create ActorMaterializerSettings from individual settings (Java).

Parameters:

initialInputBufferSize - (undocumented)

maxInputBufferSize - (undocumented)

dispatcher - (undocumented)

supervisionDecider - (undocumented)

subscriptionTimeoutSettings - (undocumented)

debugLogging - (undocumented)

outputBurstLimit - (undocumented)

fuzzingMode - (undocumented)

autoFusing - (undocumented)

maxFixedBufferSize - (undocumented)

Returns:

(undocumented)

create

public ActorMaterializerSettings create(ActorSystem system)

Create ActorMaterializerSettings from the settings of an ActorSystem (Java).

Parameters:

system - (undocumented)

Returns:

(undocumented)

create

public ActorMaterializerSettings create(com.typesafe.config.Config config)

Create ActorMaterializerSettings from a Config subsection (Java).

Parameters:

config - (undocumented)

Returns:

(undocumented)