Package akka.stream.impl.io
Class InputStreamSource
- java.lang.Object
-
- akka.stream.impl.SourceModule<ByteString,scala.concurrent.Future<IOResult>>
-
- akka.stream.impl.io.InputStreamSource
-
- All Implemented Interfaces:
Graph<SourceShape<ByteString>,scala.concurrent.Future<IOResult>>
,StreamLayout.AtomicModule<SourceShape<ByteString>,scala.concurrent.Future<IOResult>>
public final class InputStreamSource extends SourceModule<ByteString,scala.concurrent.Future<IOResult>>
INTERNAL API Source backed by the given input stream.
-
-
Constructor Summary
Constructors Constructor Description InputStreamSource(scala.Function0<java.io.InputStream> createInputStream, int chunkSize, Attributes attributes, SourceShape<ByteString> shape)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Attributes
attributes()
scala.Tuple2<org.reactivestreams.Publisher<ByteString>,scala.concurrent.Future<IOResult>>
create(MaterializationContext context)
protected SourceModule<ByteString,scala.concurrent.Future<IOResult>>
newInstance(SourceShape<ByteString> shape)
SourceModule<ByteString,scala.concurrent.Future<IOResult>>
withAttributes(Attributes attr)
-
Methods inherited from class akka.stream.impl.SourceModule
amendShape, label, shape, toString, traversalBuilder
-
-
-
-
Constructor Detail
-
InputStreamSource
public InputStreamSource(scala.Function0<java.io.InputStream> createInputStream, int chunkSize, Attributes attributes, SourceShape<ByteString> shape)
-
-
Method Detail
-
attributes
public Attributes attributes()
- Specified by:
attributes
in classSourceModule<ByteString,scala.concurrent.Future<IOResult>>
-
create
public scala.Tuple2<org.reactivestreams.Publisher<ByteString>,scala.concurrent.Future<IOResult>> create(MaterializationContext context)
- Specified by:
create
in classSourceModule<ByteString,scala.concurrent.Future<IOResult>>
-
newInstance
protected SourceModule<ByteString,scala.concurrent.Future<IOResult>> newInstance(SourceShape<ByteString> shape)
- Specified by:
newInstance
in classSourceModule<ByteString,scala.concurrent.Future<IOResult>>
-
withAttributes
public SourceModule<ByteString,scala.concurrent.Future<IOResult>> withAttributes(Attributes attr)
-
-