public final class FileSource extends SourceModule<ByteString,scala.concurrent.Future<IOResult>>
Constructor and Description |
---|
FileSource(java.nio.file.Path f,
int chunkSize,
long startPosition,
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 java.lang.String |
label() |
protected SourceModule<ByteString,scala.concurrent.Future<IOResult>> |
newInstance(SourceShape<ByteString> shape) |
StreamLayout.Module |
withAttributes(Attributes attr) |
amendShape, carbonCopy, 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 FileSource(java.nio.file.Path f, int chunkSize, long startPosition, 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)
protected java.lang.String label()
label
in class SourceModule<ByteString,scala.concurrent.Future<IOResult>>