monitor
Materializes to a FlowMonitor
that monitors messages flowing through or completion of the operators.
Signature
def monitor[Mat2]()(combine: (Mat, FlowMonitor[Out]) => Mat2): ReprMat[Out, Mat2]
def monitorMat[Mat2](combine: (Mat, FlowMonitor[Out]) => Mat2): ReprMat[Out, Mat2]
def monitor: ReprMat[Out, (Mat, FlowMonitor[Out])]
Description
Materializes to a FlowMonitor
that monitors messages flowing through or completion of the operators. The operators otherwise passes through elements unchanged. Note that the FlowMonitor
inserts a memory barrier every time it processes an event, and may therefore affect performance.
emits when upstream emits an element
backpressures when downstream backpressures
completes when upstream completes