Package akka.stream.scaladsl

Class JavaFlowSupport.Source$

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

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      Source$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> Source<T,​java.util.concurrent.Flow.Subscriber<T>> asSubscriber()
      Creates a Source that is materialized as a Flow.Subscriber
      <T> Source<T,​NotUsed> fromPublisher​(java.util.concurrent.Flow.Publisher<T> publisher)
      Helper to create Source from Flow.Publisher.

      • 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.Source$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • Source$

        public Source$()

    • Method Detail

      • fromPublisher

        public final <T> Source<T,​NotUsed> fromPublisher​(java.util.concurrent.Flow.Publisher<T> publisher)
        Helper to create Source from Flow.Publisher.

        Construct a transformation starting with given publisher. The transformation steps are executed by a series of Flow.Processor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.

        See Also:
        also if wanting to integrate with instead (which carries the same semantics, however existed before RS's inclusion in Java 9).

      • asSubscriber

        public final <T> Source<T,​java.util.concurrent.Flow.Subscriber<T>> asSubscriber()
        Creates a Source that is materialized as a Flow.Subscriber

        See Also:
        also if wanting to integrate with instead (which carries the same semantics, however existed before RS's inclusion in Java 9).