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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

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 class SourceModule<ByteString,scala.concurrent.Future<IOResult>>

create

public scala.Tuple2<org.reactivestreams.Publisher<ByteString>,scala.concurrent.Future<IOResult>> create(MaterializationContext context)

Specified by:

create in class SourceModule<ByteString,scala.concurrent.Future<IOResult>>

newInstance

protected SourceModule<ByteString,scala.concurrent.Future<IOResult>> newInstance(SourceShape<ByteString> shape)

Specified by:

newInstance in class SourceModule<ByteString,scala.concurrent.Future<IOResult>>

withAttributes

public SourceModule<ByteString,scala.concurrent.Future<IOResult>> withAttributes(Attributes attr)