public static class StreamUtils.CaptureTerminationOp$ extends java.lang.Object implements StreamUtils.EntityStreamOp<scala.concurrent.Future<scala.runtime.BoxedUnit>>
Modifier and Type | Field and Description |
---|---|
static StreamUtils.CaptureTerminationOp$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
CaptureTerminationOp$() |
Modifier and Type | Method and Description |
---|---|
<T,Mat> scala.Tuple2<org.apache.pekko.stream.scaladsl.Source<T,Mat>,scala.concurrent.Future<scala.runtime.BoxedUnit>> |
apply(org.apache.pekko.stream.scaladsl.Source<T,Mat> source) |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
strictM() |
public static final StreamUtils.CaptureTerminationOp$ MODULE$
public scala.concurrent.Future<scala.runtime.BoxedUnit> strictM()
strictM
in interface StreamUtils.EntityStreamOp<scala.concurrent.Future<scala.runtime.BoxedUnit>>
public <T,Mat> scala.Tuple2<org.apache.pekko.stream.scaladsl.Source<T,Mat>,scala.concurrent.Future<scala.runtime.BoxedUnit>> apply(org.apache.pekko.stream.scaladsl.Source<T,Mat> source)
apply
in interface StreamUtils.EntityStreamOp<scala.concurrent.Future<scala.runtime.BoxedUnit>>