Package org.apache.pekko.stream.scaladsl

Class UnzipWith$

java.lang.Object

org.apache.pekko.stream.scaladsl.UnzipWith$

All Implemented Interfaces:

UnzipWithApply

public class UnzipWith$
extends Object
implements UnzipWithApply

Transforms each element of input stream into multiple streams using a splitter function.

'''Emits when''' all of the outputs stop backpressuring and there is an input element available

'''Backpressures when''' any of the outputs backpressure

'''Completes when''' upstream completes

'''Cancels when''' any downstream cancels

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.scaladsl.UnzipWithApply

UnzipWithApply.UnzipWithCreator<In,Out,T>, UnzipWithApply.UnzipWithCreator10<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10>, UnzipWithApply.UnzipWithCreator11<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11>, UnzipWithApply.UnzipWithCreator12<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12>, UnzipWithApply.UnzipWithCreator13<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13>, UnzipWithApply.UnzipWithCreator14<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14>, UnzipWithApply.UnzipWithCreator15<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15>, UnzipWithApply.UnzipWithCreator16<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16>, UnzipWithApply.UnzipWithCreator17<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17>, UnzipWithApply.UnzipWithCreator18<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18>, UnzipWithApply.UnzipWithCreator19<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19>, UnzipWithApply.UnzipWithCreator2<In,A1,A2>, UnzipWithApply.UnzipWithCreator20<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20>, UnzipWithApply.UnzipWithCreator21<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21>, UnzipWithApply.UnzipWithCreator22<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22>, UnzipWithApply.UnzipWithCreator3<In,A1,A2,A3>, UnzipWithApply.UnzipWithCreator4<In,A1,A2,A3,A4>, UnzipWithApply.UnzipWithCreator5<In,A1,A2,A3,A4,A5>, UnzipWithApply.UnzipWithCreator6<In,A1,A2,A3,A4,A5,A6>, UnzipWithApply.UnzipWithCreator7<In,A1,A2,A3,A4,A5,A6,A7>, UnzipWithApply.UnzipWithCreator8<In,A1,A2,A3,A4,A5,A6,A7,A8>, UnzipWithApply.UnzipWithCreator9<In,A1,A2,A3,A4,A5,A6,A7,A8,A9>, UnzipWithApply.UnzipWithCreatorObject10$, UnzipWithApply.UnzipWithCreatorObject11$, UnzipWithApply.UnzipWithCreatorObject12$, UnzipWithApply.UnzipWithCreatorObject13$, UnzipWithApply.UnzipWithCreatorObject14$, UnzipWithApply.UnzipWithCreatorObject15$, UnzipWithApply.UnzipWithCreatorObject16$, UnzipWithApply.UnzipWithCreatorObject17$, UnzipWithApply.UnzipWithCreatorObject18$, UnzipWithApply.UnzipWithCreatorObject19$, UnzipWithApply.UnzipWithCreatorObject2$, UnzipWithApply.UnzipWithCreatorObject20$, UnzipWithApply.UnzipWithCreatorObject21$, UnzipWithApply.UnzipWithCreatorObject22$, UnzipWithApply.UnzipWithCreatorObject3$, UnzipWithApply.UnzipWithCreatorObject4$, UnzipWithApply.UnzipWithCreatorObject5$, UnzipWithApply.UnzipWithCreatorObject6$, UnzipWithApply.UnzipWithCreatorObject7$, UnzipWithApply.UnzipWithCreatorObject8$, UnzipWithApply.UnzipWithCreatorObject9$

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
UnzipWith$()

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.UnzipWithApply

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 UnzipWith$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

UnzipWith$

public UnzipWith$()