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