Package akka.stream.impl.fusing

Class Split$

java.lang.Object

akka.stream.impl.fusing.Split$

public class Split$
extends java.lang.Object

Splits before the current element. The current element will be the first element in the new substream.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Split$()

Method Summary

Modifier and Type	Method	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)