Package org.apache.pekko.stream.javadsl

Class OrElse$

java.lang.Object

org.apache.pekko.stream.javadsl.OrElse$

public class OrElse$
extends Object

Takes two streams and passes the first through, the secondary stream is only passed through if the primary stream completes without passing any elements through. When the first element is passed through from the primary the secondary is cancelled. Both incoming streams are materialized when the operator is materialized.

On errors the operator is failed regardless of source of the error.

'''Emits when''' element is available from primary stream or the primary stream closed without emitting any elements and an element is available from the secondary stream

'''Backpressures when''' downstream backpressures

'''Completes when''' the primary stream completes after emitting at least one element, when the primary stream completes without emitting and the secondary stream already has completed or when the secondary stream completes

'''Cancels when''' downstream cancels

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
OrElse$()

Method Summary

Modifier and Type	Method	Description
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create()	Create a new OrElse operator with the specified input type.

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final OrElse$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

OrElse$

public OrElse$()

Method Details

create

public <T> Graph<UniformFanInShape<T,T>,NotUsed> create()

Create a new OrElse operator with the specified input type.