| Package | Description |
|---|---|
| io.reactiverse.neo4j | |
| io.reactiverse.reactivex.neo4j | |
| io.reactiverse.rxjava.neo4j |
| Modifier and Type | Method and Description |
|---|---|
Neo4jRecordStream |
Neo4jRecordStream.endHandler(Handler<Void> handler) |
Neo4jRecordStream |
Neo4jRecordStream.exceptionHandler(Handler<Throwable> handler) |
Neo4jRecordStream |
Neo4jRecordStream.fetch(long l) |
Neo4jRecordStream |
Neo4jRecordStream.handler(Handler<Record> handler) |
Neo4jRecordStream |
Neo4jRecordStream.pause() |
Neo4jRecordStream |
Neo4jRecordStream.resume() |
| Modifier and Type | Method and Description |
|---|---|
Neo4jClient |
Neo4jClient.queryStream(String query,
Handler<AsyncResult<Neo4jRecordStream>> recordStreamHandler)
Opens a new stream of records
|
Neo4jClient |
Neo4jClient.queryStream(String query,
Value parameters,
Handler<AsyncResult<Neo4jRecordStream>> recordStreamHandler)
Opens a new stream of records
|
| Modifier and Type | Method and Description |
|---|---|
Neo4jRecordStream |
Neo4jRecordStream.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static Neo4jRecordStream |
Neo4jRecordStream.newInstance(Neo4jRecordStream arg) |
| Constructor and Description |
|---|
Neo4jRecordStream(Neo4jRecordStream delegate) |
| Modifier and Type | Method and Description |
|---|---|
Neo4jRecordStream |
Neo4jRecordStream.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static Neo4jRecordStream |
Neo4jRecordStream.newInstance(Neo4jRecordStream arg) |
| Constructor and Description |
|---|
Neo4jRecordStream(Neo4jRecordStream delegate) |
Copyright © 2020 Eclipse. All rights reserved.