Package org.apache.pekko.http.impl.util

Class StreamUtils.StreamControl

java.lang.Object

org.apache.pekko.http.impl.util.StreamUtils.StreamControl

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

Enclosing class:

StreamUtils

public static class StreamUtils.StreamControl
extends Object
implements scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamControl(scala.concurrent.Future<scala.runtime.BoxedUnit> whenMaterialized, scala.concurrent.Future<scala.runtime.BoxedUnit> whenTerminated, scala.Option<org.apache.pekko.stream.KillSwitch> killSwitch)

Method Summary

Modifier and Type	Method	Description
scala.Option<org.apache.pekko.stream.KillSwitch>	killSwitch()
scala.concurrent.Future<scala.runtime.BoxedUnit>	whenMaterialized()
scala.concurrent.Future<scala.runtime.BoxedUnit>	whenTerminated()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

StreamControl

public StreamControl(scala.concurrent.Future<scala.runtime.BoxedUnit> whenMaterialized,
 scala.concurrent.Future<scala.runtime.BoxedUnit> whenTerminated,
 scala.Option<org.apache.pekko.stream.KillSwitch> killSwitch)

Method Details

whenMaterialized

public scala.concurrent.Future<scala.runtime.BoxedUnit> whenMaterialized()

whenTerminated

public scala.concurrent.Future<scala.runtime.BoxedUnit> whenTerminated()

killSwitch

public scala.Option<org.apache.pekko.stream.KillSwitch> killSwitch()