Package akka.stream.impl.streamref

Class StreamRefSettingsImpl

java.lang.Object

akka.stream.impl.streamref.StreamRefSettingsImpl

All Implemented Interfaces:

StreamRefSettings, java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

public final class StreamRefSettingsImpl
extends java.lang.Object
implements StreamRefSettings, scala.Product, scala.Serializable

INTERNAL API

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamRefSettingsImpl()

Method Summary

Modifier and Type	Method	Description
static StreamRefSettingsImpl	apply(int bufferCapacity, scala.concurrent.duration.FiniteDuration demandRedeliveryInterval, scala.concurrent.duration.FiniteDuration subscriptionTimeout, scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline)
int	bufferCapacity()
boolean	canEqual(java.lang.Object x$1)
StreamRefSettingsImpl	copy(int bufferCapacity, scala.concurrent.duration.FiniteDuration demandRedeliveryInterval, scala.concurrent.duration.FiniteDuration subscriptionTimeout, scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline)
int	copy$default$1()
scala.concurrent.duration.FiniteDuration	copy$default$2()
scala.concurrent.duration.FiniteDuration	copy$default$3()
scala.concurrent.duration.FiniteDuration	copy$default$4()
scala.concurrent.duration.FiniteDuration	demandRedeliveryInterval()
boolean	equals(java.lang.Object x$1)
scala.concurrent.duration.FiniteDuration	finalTerminationSignalDeadline()
int	hashCode()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
scala.concurrent.duration.FiniteDuration	subscriptionTimeout()
java.lang.String	toString()
static scala.Option<scala.Tuple4<java.lang.Object,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration>>	unapply(StreamRefSettingsImpl x$0)
StreamRefSettings	withBufferCapacity(int value)
StreamRefSettings	withDemandRedeliveryInterval(scala.concurrent.duration.FiniteDuration value)
StreamRefSettings	withSubscriptionTimeout(scala.concurrent.duration.FiniteDuration value)
StreamRefSettings	withTerminationReceivedBeforeCompletionLeeway(scala.concurrent.duration.FiniteDuration value)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamRefSettingsImpl

public StreamRefSettingsImpl()

Method Detail

apply

public static StreamRefSettingsImpl apply(int bufferCapacity,
                                          scala.concurrent.duration.FiniteDuration demandRedeliveryInterval,
                                          scala.concurrent.duration.FiniteDuration subscriptionTimeout,
                                          scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline)

unapply

public static scala.Option<scala.Tuple4<java.lang.Object,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration>> unapply(StreamRefSettingsImpl x$0)

bufferCapacity

public int bufferCapacity()

Specified by:

bufferCapacity in interface StreamRefSettings

demandRedeliveryInterval

public scala.concurrent.duration.FiniteDuration demandRedeliveryInterval()

Specified by:

demandRedeliveryInterval in interface StreamRefSettings

subscriptionTimeout

public scala.concurrent.duration.FiniteDuration subscriptionTimeout()

Specified by:

subscriptionTimeout in interface StreamRefSettings

finalTerminationSignalDeadline

public scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline()

Specified by:

finalTerminationSignalDeadline in interface StreamRefSettings

withBufferCapacity

public StreamRefSettings withBufferCapacity(int value)

Specified by:

withBufferCapacity in interface StreamRefSettings

withDemandRedeliveryInterval

public StreamRefSettings withDemandRedeliveryInterval(scala.concurrent.duration.FiniteDuration value)

Specified by:

withDemandRedeliveryInterval in interface StreamRefSettings

withSubscriptionTimeout

public StreamRefSettings withSubscriptionTimeout(scala.concurrent.duration.FiniteDuration value)

Specified by:

withSubscriptionTimeout in interface StreamRefSettings

withTerminationReceivedBeforeCompletionLeeway

public StreamRefSettings withTerminationReceivedBeforeCompletionLeeway(scala.concurrent.duration.FiniteDuration value)

Specified by:

withTerminationReceivedBeforeCompletionLeeway in interface StreamRefSettings

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

copy

public StreamRefSettingsImpl copy(int bufferCapacity,
                                  scala.concurrent.duration.FiniteDuration demandRedeliveryInterval,
                                  scala.concurrent.duration.FiniteDuration subscriptionTimeout,
                                  scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline)

copy$default$1

public int copy$default$1()

copy$default$2

public scala.concurrent.duration.FiniteDuration copy$default$2()

copy$default$3

public scala.concurrent.duration.FiniteDuration copy$default$3()

copy$default$4

public scala.concurrent.duration.FiniteDuration copy$default$4()

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object