dev.snowdrop.vertx.streams

Interface Pipe<T>

public interface Pipe<T>

Method Summary

Modifier and Type	Method and Description
void	close()
Pipe<T>	endOnComplete(boolean end)
Pipe<T>	endOnFailure(boolean end)
Pipe<T>	endOnSuccess(boolean end)
reactor.core.publisher.Mono<Void>	to(WriteStream<T> destination)

Method Detail

endOnFailure

Pipe<T> endOnFailure(boolean end)

endOnSuccess

Pipe<T> endOnSuccess(boolean end)

endOnComplete

Pipe<T> endOnComplete(boolean end)

to

reactor.core.publisher.Mono<Void> to(WriteStream<T> destination)

close

void close()