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 IProcessorDelegatepublic 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 IProcessorDelegatepublic java.lang.String toString()
toString in class java.lang.ObjectCopyright © 2024. All Rights Reserved.