io.reactiverse.neo4j

Interface Neo4jRecordStream

All Superinterfaces:

ReadStream<Record>, StreamBase

public interface Neo4jRecordStream
extends ReadStream<Record>

A ReadStream for Record consumption.

Method Summary

Modifier and Type	Method and Description
Neo4jRecordStream	endHandler(Handler<Void> handler)
Neo4jRecordStream	exceptionHandler(Handler<Throwable> handler)
Neo4jRecordStream	fetch(long l)
Neo4jRecordStream	handler(Handler<Record> handler)
Neo4jRecordStream	pause()
Neo4jRecordStream	resume()

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

pipe, pipeTo, pipeTo

Method Detail

exceptionHandler

Neo4jRecordStream exceptionHandler(Handler<Throwable> handler)

Specified by:

exceptionHandler in interface ReadStream<Record>

Specified by:

exceptionHandler in interface StreamBase

handler

Neo4jRecordStream handler(Handler<Record> handler)

Specified by:

handler in interface ReadStream<Record>

pause

Neo4jRecordStream pause()

Specified by:

pause in interface ReadStream<Record>

resume

Neo4jRecordStream resume()

Specified by:

resume in interface ReadStream<Record>

endHandler

Neo4jRecordStream endHandler(Handler<Void> handler)

Specified by:

endHandler in interface ReadStream<Record>

fetch

Neo4jRecordStream fetch(long l)

Specified by:

fetch in interface ReadStream<Record>