akka.stream.impl.fusing

Class Split$

java.lang.Object

akka.stream.impl.fusing.Split$

public class Split$
extends java.lang.Object

INTERNAL API

Field Summary

Fields

Modifier and Type	Field and Description
static Split$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Split$()

Method Summary

Modifier and Type	Method and Description
<T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed>	after(scala.Function1<T,java.lang.Object> p, SubstreamCancelStrategy substreamCancelStrategy)
<T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed>	when(scala.Function1<T,java.lang.Object> p, SubstreamCancelStrategy substreamCancelStrategy)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Split$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Split$

public Split$()

Method Detail

when

public <T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed> when(scala.Function1<T,java.lang.Object> p,
                                                              SubstreamCancelStrategy substreamCancelStrategy)

after

public <T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed> after(scala.Function1<T,java.lang.Object> p,
                                                               SubstreamCancelStrategy substreamCancelStrategy)