io.reactiverse.pgclient

Interface PgStream<T>

All Superinterfaces:

io.vertx.core.streams.ReadStream<T>, io.vertx.core.streams.StreamBase

public interface PgStream<T>
extends io.vertx.core.streams.ReadStream<T>

A row oriented stream.

Method Summary

Modifier and Type	Method and Description
void	close() Close the stream and release the resources.
void	close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler) Close the stream and release the resources.
PgStream<T>	endHandler(io.vertx.core.Handler<Void> endHandler)
PgStream<T>	exceptionHandler(io.vertx.core.Handler<Throwable> handler)
PgStream<T>	handler(io.vertx.core.Handler<T> handler)
PgStream<T>	pause()
PgStream<T>	resume()

Methods inherited from interface io.vertx.core.streams.ReadStream

fetch

Method Detail

exceptionHandler

PgStream<T> exceptionHandler(io.vertx.core.Handler<Throwable> handler)

Specified by:

exceptionHandler in interface io.vertx.core.streams.ReadStream<T>

Specified by:

exceptionHandler in interface io.vertx.core.streams.StreamBase

handler

PgStream<T> handler(io.vertx.core.Handler<T> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<T>

pause

PgStream<T> pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<T>

resume

PgStream<T> resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<T>

endHandler

PgStream<T> endHandler(io.vertx.core.Handler<Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<T>

close

void close()

Close the stream and release the resources.

close

void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)

Close the stream and release the resources.

Parameters:

completionHandler - the completion handler for this operation