Package org.apache.pekko.stream.scaladsl

Class ZipWith$

java.lang.Object

org.apache.pekko.stream.scaladsl.ZipWith$

All Implemented Interfaces:

ZipWithApply

public class ZipWith$
extends Object
implements ZipWithApply

Combine the elements of multiple streams into a stream of combined elements using a combiner function.

'''Emits when''' all of the inputs has an element available

'''Backpressures when''' downstream backpressures

'''Completes when''' any upstream completes

'''Cancels when''' downstream cancels

Adheres to the ActorAttributes.SupervisionStrategy attribute.

If the combiner function throws and the supervision decision is pekko.stream.Supervision.Stop the stream fails. If the supervision decision is pekko.stream.Supervision.Resume or pekko.stream.Supervision.Restart the zipped element is dropped and the stream continues.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ZipWith$()

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.stream.scaladsl.ZipWithApply

apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply

Field Details

MODULE$

public static final ZipWith$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ZipWith$

public ZipWith$()