JavaFlowSupport.Source

java.lang.Object
- akka.stream.javadsl.JavaFlowSupport.Source

Enclosing class:

JavaFlowSupport
```
public static final class JavaFlowSupport.Source
extends java.lang.Object
```
{@link akka.stream.javadsl.Flow]] factories operating with java.util.concurrent.Flow.* interfaces.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> Source<T,java.util.concurrent.Flow.Subscriber<T>>`	`asSubscriber()`	Creates a `Source` that is materialized as a `Flow.Subscriber`.
`static <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

- Method Detail
  - fromPublisher
```
public static <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 Source.fromPublisher if wanting to integrate with Publisher instead (which carries the same semantics, however existed before RS's inclusion in Java 9).
  - asSubscriber
```
public static <T> Source<T,java.util.concurrent.Flow.Subscriber<T>> asSubscriber()
```
    Creates a Source that is materialized as a Flow.Subscriber.
    See also Source.asSubscriber if wanting to integrate with Subscriber instead (which carries the same semantics, however existed before RS's inclusion in Java 9).