Class ZipWithN<A,​O>

  • All Implemented Interfaces:
    Graph<UniformFanInShape<A,​O>,​NotUsed>
    Direct Known Subclasses:
    ZipN

    public class ZipWithN<A,​O>
    extends GraphStage<UniformFanInShape<A,​O>>
    Combine the elements of multiple streams into a stream of sequences using a combiner function.

    A ZipWithN has a n input ports and one out port

    '''Emits when''' all of the inputs has an element available

    '''Backpressures when''' downstream backpressures

    '''Completes when''' any upstream completes

    '''Cancels when''' downstream cancels

    • Constructor Detail

      • ZipWithN

        public ZipWithN​(scala.Function1<scala.collection.immutable.Seq<A>,​O> zipper,
                        int n)
    • Method Detail

      • apply

        public static <A,​O> ZipWithN<A,​O> apply​(scala.Function1<scala.collection.immutable.Seq<A>,​O> zipper,
                                                            int n)
        Create a new ZipWithN.
        Parameters:
        zipper - (undocumented)
        n - (undocumented)
        Returns:
        (undocumented)
      • named

        public static Graph<S,​M> named​(java.lang.String name)
      • async

        public static Graph<S,​M> async()
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher)
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher,
                                             int inputBufferSize)
      • addAttributes

        public static Graph<S,​M> addAttributes​(Attributes attr)
      • withAttributes

        public static final Graph<S,​M> withAttributes​(Attributes attr)
      • createLogicAndMaterializedValue

        public static final scala.Tuple2<GraphStageLogic,​NotUsed> createLogicAndMaterializedValue​(Attributes inheritedAttributes)
      • shape

        public UniformFanInShape<A,​O> shape()
        Description copied from interface: Graph
        The shape of a graph is all that is externally visible: its inlets and outlets.
        Returns:
        (undocumented)
      • inSeq

        public scala.collection.immutable.IndexedSeq<Inlet<A>> inSeq()
        Deprecated.
        use `shape.inlets` or `shape.in(id)` instead. Since 2.5.5.
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object