Class UnzipWith


  • public class UnzipWith
    extends java.lang.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

    • Constructor Summary

      Constructors 
      Constructor Description
      UnzipWith()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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.
      static <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
    • Constructor Detail

      • UnzipWith

        public UnzipWith()
    • Method Detail

      • create

        public static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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 static <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