Package org.apache.pekko.stream.javadsl

Class WireTap

java.lang.Object

org.apache.pekko.stream.javadsl.WireTap

public class WireTap
extends Object

Fan-out the stream to two output streams - a 'main' and a 'tap' one. Each incoming element is emitted to the 'main' output; elements are also emitted to the 'tap' output if there is demand; otherwise they are dropped.

'''Emits when''' element is available and demand exists from the 'main' output; the element will also be sent to the 'tap' output if there is demand.

'''Backpressures when''' the 'main' output backpressures

'''Completes when''' upstream completes

'''Cancels when''' the 'main' output cancels

Constructor Summary

Constructors

Constructor	Description
WireTap()

Method Summary

Modifier and Type	Method	Description
static <T> Graph<FanOutShape2<T,T,T>,NotUsed>	create()	Create a new WireTap operator with the specified output type.

Methods inherited from class java.lang.Object

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

Constructor Details

WireTap

public WireTap()

Method Details

create

public static <T>
Graph<FanOutShape2<T,T,T>,NotUsed> create()

Create a new WireTap operator with the specified output type.