Package org.apache.pekko.stream.scaladsl

Class UnzipWith

java.lang.Object

org.apache.pekko.stream.scaladsl.UnzipWith

public class UnzipWith
extends Object

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

Constructor Summary

Constructors

Constructor	Description
UnzipWith()

Method Summary

Modifier and Type	Method	Description
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10> UnzipWith10<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10>	apply(scala.Function1<In,scala.Tuple10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10>> unzipper, UnzipWithApply.UnzipWithCreator10<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11> UnzipWith11<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11>	apply(scala.Function1<In,scala.Tuple11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11>> unzipper, UnzipWithApply.UnzipWithCreator11<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12> UnzipWith12<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12>	apply(scala.Function1<In,scala.Tuple12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12>> unzipper, UnzipWithApply.UnzipWithCreator12<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13> UnzipWith13<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13>	apply(scala.Function1<In,scala.Tuple13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13>> unzipper, UnzipWithApply.UnzipWithCreator13<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14> UnzipWith14<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14>	apply(scala.Function1<In,scala.Tuple14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14>> unzipper, UnzipWithApply.UnzipWithCreator14<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15> UnzipWith15<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15>	apply(scala.Function1<In,scala.Tuple15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15>> unzipper, UnzipWithApply.UnzipWithCreator15<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16> UnzipWith16<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16>	apply(scala.Function1<In,scala.Tuple16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16>> unzipper, UnzipWithApply.UnzipWithCreator16<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17> UnzipWith17<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17>	apply(scala.Function1<In,scala.Tuple17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17>> unzipper, UnzipWithApply.UnzipWithCreator17<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18> UnzipWith18<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18>	apply(scala.Function1<In,scala.Tuple18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18>> unzipper, UnzipWithApply.UnzipWithCreator18<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19> UnzipWith19<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19>	apply(scala.Function1<In,scala.Tuple19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19>> unzipper, UnzipWithApply.UnzipWithCreator19<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2> UnzipWith2<In,A1,A2>	apply(scala.Function1<In,scala.Tuple2<A1,A2>> unzipper, UnzipWithApply.UnzipWithCreator2<Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20> UnzipWith20<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20>	apply(scala.Function1<In,scala.Tuple20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20>> unzipper, UnzipWithApply.UnzipWithCreator20<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21> UnzipWith21<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21>	apply(scala.Function1<In,scala.Tuple21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21>> unzipper, UnzipWithApply.UnzipWithCreator21<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22> UnzipWith22<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22>	apply(scala.Function1<In,scala.Tuple22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22>> unzipper, UnzipWithApply.UnzipWithCreator22<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3> UnzipWith3<In,A1,A2,A3>	apply(scala.Function1<In,scala.Tuple3<A1,A2,A3>> unzipper, UnzipWithApply.UnzipWithCreator3<Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4> UnzipWith4<In,A1,A2,A3,A4>	apply(scala.Function1<In,scala.Tuple4<A1,A2,A3,A4>> unzipper, UnzipWithApply.UnzipWithCreator4<Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5> UnzipWith5<In,A1,A2,A3,A4,A5>	apply(scala.Function1<In,scala.Tuple5<A1,A2,A3,A4,A5>> unzipper, UnzipWithApply.UnzipWithCreator5<Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6> UnzipWith6<In,A1,A2,A3,A4,A5,A6>	apply(scala.Function1<In,scala.Tuple6<A1,A2,A3,A4,A5,A6>> unzipper, UnzipWithApply.UnzipWithCreator6<Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7> UnzipWith7<In,A1,A2,A3,A4,A5,A6,A7>	apply(scala.Function1<In,scala.Tuple7<A1,A2,A3,A4,A5,A6,A7>> unzipper, UnzipWithApply.UnzipWithCreator7<Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8> UnzipWith8<In,A1,A2,A3,A4,A5,A6,A7,A8>	apply(scala.Function1<In,scala.Tuple8<A1,A2,A3,A4,A5,A6,A7,A8>> unzipper, UnzipWithApply.UnzipWithCreator8<Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)
static <In, A1, A2, A3, A4, A5, A6, A7, A8, A9> UnzipWith9<In,A1,A2,A3,A4,A5,A6,A7,A8,A9>	apply(scala.Function1<In,scala.Tuple9<A1,A2,A3,A4,A5,A6,A7,A8,A9>> unzipper, UnzipWithApply.UnzipWithCreator9<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

Methods inherited from class java.lang.Object

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

Constructor Details

UnzipWith

public UnzipWith()

Method Details

apply

public static <In,
A1,
A2> UnzipWith2<In,A1,A2> apply(scala.Function1<In,scala.Tuple2<A1,A2>> unzipper,
 UnzipWithApply.UnzipWithCreator2<Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3> UnzipWith3<In,A1,A2,A3> apply(scala.Function1<In,scala.Tuple3<A1,A2,A3>> unzipper,
 UnzipWithApply.UnzipWithCreator3<Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4>
UnzipWith4<In,A1,A2,A3,A4> apply(scala.Function1<In,scala.Tuple4<A1,A2,A3,A4>> unzipper,
 UnzipWithApply.UnzipWithCreator4<Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5>
UnzipWith5<In,A1,A2,A3,A4,A5> apply(scala.Function1<In,scala.Tuple5<A1,A2,A3,A4,A5>> unzipper,
 UnzipWithApply.UnzipWithCreator5<Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6>
UnzipWith6<In,A1,A2,A3,A4,A5,A6> apply(scala.Function1<In,scala.Tuple6<A1,A2,A3,A4,A5,A6>> unzipper,
 UnzipWithApply.UnzipWithCreator6<Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7>
UnzipWith7<In,A1,A2,A3,A4,A5,A6,A7> apply(scala.Function1<In,scala.Tuple7<A1,A2,A3,A4,A5,A6,A7>> unzipper,
 UnzipWithApply.UnzipWithCreator7<Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8>
UnzipWith8<In,A1,A2,A3,A4,A5,A6,A7,A8> apply(scala.Function1<In,scala.Tuple8<A1,A2,A3,A4,A5,A6,A7,A8>> unzipper,
 UnzipWithApply.UnzipWithCreator8<Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9>
UnzipWith9<In,A1,A2,A3,A4,A5,A6,A7,A8,A9> apply(scala.Function1<In,scala.Tuple9<A1,A2,A3,A4,A5,A6,A7,A8,A9>> unzipper,
 UnzipWithApply.UnzipWithCreator9<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10>
UnzipWith10<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10> apply(scala.Function1<In,scala.Tuple10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10>> unzipper,
 UnzipWithApply.UnzipWithCreator10<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11>
UnzipWith11<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11> apply(scala.Function1<In,scala.Tuple11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11>> unzipper,
 UnzipWithApply.UnzipWithCreator11<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12>
UnzipWith12<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12> apply(scala.Function1<In,scala.Tuple12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12>> unzipper,
 UnzipWithApply.UnzipWithCreator12<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13>
UnzipWith13<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13> apply(scala.Function1<In,scala.Tuple13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13>> unzipper,
 UnzipWithApply.UnzipWithCreator13<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14>
UnzipWith14<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14> apply(scala.Function1<In,scala.Tuple14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14>> unzipper,
 UnzipWithApply.UnzipWithCreator14<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15>
UnzipWith15<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15> apply(scala.Function1<In,scala.Tuple15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15>> unzipper,
 UnzipWithApply.UnzipWithCreator15<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16>
UnzipWith16<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16> apply(scala.Function1<In,scala.Tuple16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16>> unzipper,
 UnzipWithApply.UnzipWithCreator16<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16,
A17>
UnzipWith17<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17> apply(scala.Function1<In,scala.Tuple17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17>> unzipper,
 UnzipWithApply.UnzipWithCreator17<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16,
A17,
A18>
UnzipWith18<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18> apply(scala.Function1<In,scala.Tuple18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18>> unzipper,
 UnzipWithApply.UnzipWithCreator18<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16,
A17,
A18,
A19>
UnzipWith19<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19> apply(scala.Function1<In,scala.Tuple19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19>> unzipper,
 UnzipWithApply.UnzipWithCreator19<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16,
A17,
A18,
A19,
A20>
UnzipWith20<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20> apply(scala.Function1<In,scala.Tuple20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20>> unzipper,
 UnzipWithApply.UnzipWithCreator20<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16,
A17,
A18,
A19,
A20,
A21>
UnzipWith21<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21> apply(scala.Function1<In,scala.Tuple21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21>> unzipper,
 UnzipWithApply.UnzipWithCreator21<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)

apply

public static <In,
A1,
A2,
A3,
A4,
A5,
A6,
A7,
A8,
A9,
A10,
A11,
A12,
A13,
A14,
A15,
A16,
A17,
A18,
A19,
A20,
A21,
A22>
UnzipWith22<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22> apply(scala.Function1<In,scala.Tuple22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22>> unzipper,
 UnzipWithApply.UnzipWithCreator22<Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object,Object> creator)