public class StreamSinkProcessor extends java.lang.Object implements IProcessorDelegate
Constructor and Description |
---|
StreamSinkProcessor(java.lang.String conId,
java.lang.String selected,
long uid,
java.lang.String part,
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> sink) |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>> |
delegateStream() |
java.util.concurrent.CompletableFuture<java.lang.Void> |
future() |
void |
processText(ImapChunker.ImapChunk ic) |
java.lang.String |
toString() |
public StreamSinkProcessor(java.lang.String conId, java.lang.String selected, long uid, java.lang.String part, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> sink)
public void processText(ImapChunker.ImapChunk ic)
processText
in interface IProcessorDelegate
public java.util.concurrent.CompletableFuture<java.lang.Void> future()
public java.util.Optional<io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>> delegateStream()
delegateStream
in interface IProcessorDelegate
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2021. All Rights Reserved.