Package com.datastax.dse.driver.api.core.graph.reactive

Interface ReactiveGraphSession

All Superinterfaces:

AsyncAutoCloseable, AutoCloseable, Session

All Known Subinterfaces:

CqlSession, DseSession

public interface ReactiveGraphSession
extends Session

A Session that offers utility methods to issue graph queries using reactive-style programming.

Field Summary

Fields inherited from interface com.datastax.oss.driver.api.core.session.Session

OSS_DRIVER_COORDINATES

Method Summary

Modifier and Type	Method	Description
default ReactiveGraphResultSet	executeReactive(GraphStatement<?> statement)	Returns a ReactiveGraphResultSet that, once subscribed to, executes the given query and emits all the results.

Methods inherited from interface com.datastax.oss.driver.api.core.AsyncAutoCloseable

close, closeAsync, closeFuture, forceCloseAsync, isClosed

Methods inherited from interface com.datastax.oss.driver.api.core.session.Session

checkSchemaAgreement, checkSchemaAgreementAsync, execute, getContext, getKeyspace, getMetadata, getMetrics, getName, isSchemaMetadataEnabled, refreshSchema, refreshSchemaAsync, setSchemaMetadataEnabled

Method Detail

executeReactive

@NonNull
default ReactiveGraphResultSet executeReactive(@NonNull
                                               GraphStatement<?> statement)

Returns a 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.

Parameters:

statement - the statement to execute.

Returns:

The ReactiveGraphResultSet that will publish the returned results.

See Also:

ReactiveGraphResultSet, ReactiveGraphNode