Package akka.stream

Interface StreamRefSettings

All Known Implementing Classes:

StreamRefSettingsImpl

public interface StreamRefSettings

Settings specific to SourceRef and SinkRef. More detailed documentation about each of the settings is available in reference.conf.

Method Summary

Modifier and Type	Method	Description
int	bufferCapacity()
scala.concurrent.duration.FiniteDuration	demandRedeliveryInterval()
scala.concurrent.duration.FiniteDuration	finalTerminationSignalDeadline()
scala.concurrent.duration.FiniteDuration	subscriptionTimeout()
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)

Method Detail

bufferCapacity

int bufferCapacity()

demandRedeliveryInterval

scala.concurrent.duration.FiniteDuration demandRedeliveryInterval()

subscriptionTimeout

scala.concurrent.duration.FiniteDuration subscriptionTimeout()

finalTerminationSignalDeadline

scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline()

withBufferCapacity

StreamRefSettings withBufferCapacity(int value)

withDemandRedeliveryInterval

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

withSubscriptionTimeout

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

withTerminationReceivedBeforeCompletionLeeway

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