public final class InputStreamSource extends SourceModule<ByteString,scala.concurrent.Future<IOResult>>
Constructor and Description |
---|
InputStreamSource(scala.Function0<java.io.InputStream> createInputStream,
int chunkSize,
Attributes attributes,
SourceShape<ByteString> shape) |
Modifier and Type | Method and 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) |
StreamLayout.Module |
withAttributes(Attributes attr) |
amendShape, carbonCopy, label, replaceShape, shape, toString
downstreams, inPorts, outPorts, subModules, upstreams
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire
public InputStreamSource(scala.Function0<java.io.InputStream> createInputStream, int chunkSize, Attributes attributes, SourceShape<ByteString> shape)
public Attributes attributes()
public scala.Tuple2<org.reactivestreams.Publisher<ByteString>,scala.concurrent.Future<IOResult>> create(MaterializationContext context)
create
in class SourceModule<ByteString,scala.concurrent.Future<IOResult>>
protected SourceModule<ByteString,scala.concurrent.Future<IOResult>> newInstance(SourceShape<ByteString> shape)
newInstance
in class SourceModule<ByteString,scala.concurrent.Future<IOResult>>
public StreamLayout.Module withAttributes(Attributes attr)