public interface ReactiveGraphSession extends Session
Session
that offers utility methods to issue graph queries using reactive-style
programming.OSS_DRIVER_COORDINATES
Modifier and Type | Method and Description |
---|---|
default ReactiveGraphResultSet |
executeReactive(GraphStatement<?> statement)
Returns a
ReactiveGraphResultSet that, once subscribed to, executes the given query and
emits all the results. |
checkSchemaAgreement, checkSchemaAgreementAsync, execute, getContext, getKeyspace, getMetadata, getMetrics, getName, isSchemaMetadataEnabled, refreshSchema, refreshSchemaAsync, setSchemaMetadataEnabled
close, closeAsync, closeFuture, forceCloseAsync, isClosed
@NonNull default ReactiveGraphResultSet executeReactive(@NonNull GraphStatement<?> statement)
ReactiveGraphResultSet
that, once subscribed to, executes the given query and
emits all the results.
See the javadocs of ReactiveGraphResultSet
for important remarks anc caveats
regarding the subscription to and consumption of reactive graph result sets.
statement
- the statement to execute.ReactiveGraphResultSet
that will publish the returned results.ReactiveGraphResultSet
,
ReactiveGraphNode
Copyright © 2017–2020. All rights reserved.