Package org.apache.pekko.stream.javadsl

Class UnzipWith$

java.lang.Object
org.apache.pekko.stream.javadsl.UnzipWith$
public class UnzipWith$ extends Object
Split one stream into several streams using a splitting function.

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

'''Backpressures when''' any of the outputs backpressures

'''Completes when''' upstream completes

'''Cancels when''' any downstream cancels

  • 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

    Modifier and Type
    Method
    Description
    <In, A, B> Graph<FanOutShape2<In,A,B>,NotUsed>
    create(Function<In,Pair<A,B>> f)
    Create a new UnzipWith vertex with the specified input type and unzipping-function f.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>
    Graph<FanOutShape10<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>,NotUsed>
    create10(Function<In,Tuple10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> f)
    Create a new UnzipWith specialized for 10 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>
    Graph<FanOutShape11<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>,NotUsed>
    create11(Function<In,Tuple11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> f)
    Create a new UnzipWith specialized for 11 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>
    Graph<FanOutShape12<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>,NotUsed>
    create12(Function<In,Tuple12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> f)
    Create a new UnzipWith specialized for 12 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>
    Graph<FanOutShape13<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>,NotUsed>
    create13(Function<In,Tuple13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> f)
    Create a new UnzipWith specialized for 13 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>
    Graph<FanOutShape14<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>,NotUsed>
    create14(Function<In,Tuple14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> f)
    Create a new UnzipWith specialized for 14 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>
    Graph<FanOutShape15<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>,NotUsed>
    create15(Function<In,Tuple15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> f)
    Create a new UnzipWith specialized for 15 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>
    Graph<FanOutShape16<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>,NotUsed>
    create16(Function<In,Tuple16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> f)
    Create a new UnzipWith specialized for 16 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17>
    Graph<FanOutShape17<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>,NotUsed>
    create17(Function<In,Tuple17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> f)
    Create a new UnzipWith specialized for 17 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18>
    Graph<FanOutShape18<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>,NotUsed>
    create18(Function<In,Tuple18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> f)
    Create a new UnzipWith specialized for 18 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19>
    Graph<FanOutShape19<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>,NotUsed>
    create19(Function<In,Tuple19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> f)
    Create a new UnzipWith specialized for 19 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20>
    Graph<FanOutShape20<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>,NotUsed>
    create20(Function<In,Tuple20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> f)
    Create a new UnzipWith specialized for 20 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21>
    Graph<FanOutShape21<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>,NotUsed>
    create21(Function<In,Tuple21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> f)
    Create a new UnzipWith specialized for 21 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22>
    Graph<FanOutShape22<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>,NotUsed>
    create22(Function<In,Tuple22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> f)
    Create a new UnzipWith specialized for 22 outputs.
    <In, T1, T2, T3>
    Graph<FanOutShape3<In,T1,T2,T3>,NotUsed>
    create3(Function<In,Tuple3<T1,T2,T3>> f)
    Create a new UnzipWith specialized for 3 outputs.
    <In, T1, T2, T3, T4>
    Graph<FanOutShape4<In,T1,T2,T3,T4>,NotUsed>
    create4(Function<In,Tuple4<T1,T2,T3,T4>> f)
    Create a new UnzipWith specialized for 4 outputs.
    <In, T1, T2, T3, T4, T5>
    Graph<FanOutShape5<In,T1,T2,T3,T4,T5>,NotUsed>
    create5(Function<In,Tuple5<T1,T2,T3,T4,T5>> f)
    Create a new UnzipWith specialized for 5 outputs.
    <In, T1, T2, T3, T4, T5, T6>
    Graph<FanOutShape6<In,T1,T2,T3,T4,T5,T6>,NotUsed>
    create6(Function<In,Tuple6<T1,T2,T3,T4,T5,T6>> f)
    Create a new UnzipWith specialized for 6 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7>
    Graph<FanOutShape7<In,T1,T2,T3,T4,T5,T6,T7>,NotUsed>
    create7(Function<In,Tuple7<T1,T2,T3,T4,T5,T6,T7>> f)
    Create a new UnzipWith specialized for 7 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8>
    Graph<FanOutShape8<In,T1,T2,T3,T4,T5,T6,T7,T8>,NotUsed>
    create8(Function<In,Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>> f)
    Create a new UnzipWith specialized for 8 outputs.
    <In, T1, T2, T3, T4, T5, T6, T7, T8, T9>
    Graph<FanOutShape9<In,T1,T2,T3,T4,T5,T6,T7,T8,T9>,NotUsed>
    create9(Function<In,Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>> f)
    Create a new UnzipWith specialized for 9 outputs.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

      public static final UnzipWith$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • UnzipWith$

      public UnzipWith$()

  • Method Details

    • create

      public <In, A, B> Graph<FanOutShape2<In,A,B>,NotUsed> create(Function<In,Pair<A,B>> f)
      Create a new UnzipWith vertex with the specified input type and unzipping-function f.

      Parameters:
      f - unzipping-function from the input value to the pair of output values

    • create3

      public <In, T1, T2, T3> Graph<FanOutShape3<In,T1,T2,T3>,NotUsed> create3(Function<In,Tuple3<T1,T2,T3>> f)
      Create a new UnzipWith specialized for 3 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create4

      public <In, T1, T2, T3, T4> Graph<FanOutShape4<In,T1,T2,T3,T4>,NotUsed> create4(Function<In,Tuple4<T1,T2,T3,T4>> f)
      Create a new UnzipWith specialized for 4 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create5

      public <In, T1, T2, T3, T4, T5> Graph<FanOutShape5<In,T1,T2,T3,T4,T5>,NotUsed> create5(Function<In,Tuple5<T1,T2,T3,T4,T5>> f)
      Create a new UnzipWith specialized for 5 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create6

      public <In, T1, T2, T3, T4, T5, T6> Graph<FanOutShape6<In,T1,T2,T3,T4,T5,T6>,NotUsed> create6(Function<In,Tuple6<T1,T2,T3,T4,T5,T6>> f)
      Create a new UnzipWith specialized for 6 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create7

      public <In, T1, T2, T3, T4, T5, T6, T7> Graph<FanOutShape7<In,T1,T2,T3,T4,T5,T6,T7>,NotUsed> create7(Function<In,Tuple7<T1,T2,T3,T4,T5,T6,T7>> f)
      Create a new UnzipWith specialized for 7 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create8

      public <In, T1, T2, T3, T4, T5, T6, T7, T8> Graph<FanOutShape8<In,T1,T2,T3,T4,T5,T6,T7,T8>,NotUsed> create8(Function<In,Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>> f)
      Create a new UnzipWith specialized for 8 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create9

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9> Graph<FanOutShape9<In,T1,T2,T3,T4,T5,T6,T7,T8,T9>,NotUsed> create9(Function<In,Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>> f)
      Create a new UnzipWith specialized for 9 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create10

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> Graph<FanOutShape10<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>,NotUsed> create10(Function<In,Tuple10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> f)
      Create a new UnzipWith specialized for 10 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create11

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> Graph<FanOutShape11<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>,NotUsed> create11(Function<In,Tuple11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> f)
      Create a new UnzipWith specialized for 11 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create12

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> Graph<FanOutShape12<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>,NotUsed> create12(Function<In,Tuple12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> f)
      Create a new UnzipWith specialized for 12 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create13

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> Graph<FanOutShape13<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>,NotUsed> create13(Function<In,Tuple13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> f)
      Create a new UnzipWith specialized for 13 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create14

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> Graph<FanOutShape14<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>,NotUsed> create14(Function<In,Tuple14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> f)
      Create a new UnzipWith specialized for 14 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create15

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> Graph<FanOutShape15<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>,NotUsed> create15(Function<In,Tuple15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> f)
      Create a new UnzipWith specialized for 15 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create16

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> Graph<FanOutShape16<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>,NotUsed> create16(Function<In,Tuple16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> f)
      Create a new UnzipWith specialized for 16 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create17

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17> Graph<FanOutShape17<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>,NotUsed> create17(Function<In,Tuple17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> f)
      Create a new UnzipWith specialized for 17 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create18

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18> Graph<FanOutShape18<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>,NotUsed> create18(Function<In,Tuple18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> f)
      Create a new UnzipWith specialized for 18 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create19

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19> Graph<FanOutShape19<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>,NotUsed> create19(Function<In,Tuple19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> f)
      Create a new UnzipWith specialized for 19 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create20

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20> Graph<FanOutShape20<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>,NotUsed> create20(Function<In,Tuple20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> f)
      Create a new UnzipWith specialized for 20 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create21

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21> Graph<FanOutShape21<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>,NotUsed> create21(Function<In,Tuple21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> f)
      Create a new UnzipWith specialized for 21 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values

    • create22

      public <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22> Graph<FanOutShape22<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>,NotUsed> create22(Function<In,Tuple22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> f)
      Create a new UnzipWith specialized for 22 outputs.

      Parameters:
      f - unzipping-function from the input value to the output values