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

    • Field Summary

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

      Constructors 
      Constructor Description
      UnzipWith$()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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 Detail

      • MODULE$

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

      • UnzipWith$

        public UnzipWith$()
    • Method Detail

      • 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