Package akka.stream.scaladsl

Class JavaFlowSupport.Sink$

  • Enclosing class:
    JavaFlowSupport
    public static class JavaFlowSupport.Sink$
extends java.lang.Object
    Sink factories operating with java.util.concurrent.Flow.* interfaces.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static JavaFlowSupport.Sink$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Constructor Summary

      Constructors 
      Constructor Description
      Sink$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> Sink<T,​java.util.concurrent.Flow.Publisher<T>> asPublisher​(boolean fanout)
      A Sink that materializes into a Flow.Publisher.
      <T> Sink<T,​NotUsed> fromSubscriber​(java.util.concurrent.Flow.Subscriber<T> s)
      Helper to create Sink from Flow.Subscriber.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

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

    • Constructor Detail

      • Sink$

        public Sink$()

    • Method Detail

      • asPublisher

        public final <T> Sink<T,​java.util.concurrent.Flow.Publisher<T>> asPublisher​(boolean fanout)
        A Sink that materializes into a Flow.Publisher.

        If fanout is WITH_FANOUT, the materialized Publisher will support multiple Subscribers and the size of the inputBuffer configured for this operator becomes the maximum number of elements that the fastest Flow.Subscriber can be ahead of the slowest one before slowing the processing down due to back pressure.

        If fanout is WITHOUT_FANOUT then the materialized Publisher will only support a single Subscriber and reject any additional Subscribers.

      • fromSubscriber

        public final <T> Sink<T,​NotUsed> fromSubscriber​(java.util.concurrent.Flow.Subscriber<T> s)
        Helper to create Sink from Flow.Subscriber.