Module org.neo4j.driver

Package org.neo4j.driver.internal.reactive

Class AbstractReactiveSession<S>

java.lang.Object

org.neo4j.driver.internal.reactive.AbstractReactiveSession<S>

Direct Known Subclasses:

InternalReactiveSession, InternalReactiveSession

public abstract class AbstractReactiveSession<S>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final NetworkSession	session

Constructor Summary

Constructors

Constructor	Description
AbstractReactiveSession(NetworkSession session)

Method Summary

Modifier and Type	Method	Description
protected abstract org.reactivestreams.Publisher<Void>	closeTransaction(S transaction, boolean commit, Observation parentObservation)
protected abstract S	createTransaction(UnmanagedTransaction unmanagedTransaction)
protected org.reactivestreams.Publisher<S>	doBeginTransaction(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
protected <T> org.reactivestreams.Publisher<T>	doClose(Observation parentObservation)
Set<Bookmark>	lastBookmarks()
protected <T> org.reactivestreams.Publisher<T>	run(Query query, TransactionConfig config, Function<RxResultCursor,T> cursorToResult, Observation parentObservation)
protected <T> org.reactivestreams.Publisher<T>	runTransaction(AccessMode mode, Function<S,? extends org.reactivestreams.Publisher<T>> work, TransactionConfig config, Class<? extends BaseSession> sessionType, DriverObservationProvider observationProvider)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

session

protected final NetworkSession session

Constructor Details

AbstractReactiveSession

public AbstractReactiveSession(NetworkSession session)

Method Details

createTransaction

protected abstract S createTransaction(UnmanagedTransaction unmanagedTransaction)

closeTransaction

protected abstract org.reactivestreams.Publisher<Void> closeTransaction(S transaction,
 boolean commit,
 Observation parentObservation)

doBeginTransaction

protected org.reactivestreams.Publisher<S> doBeginTransaction(TransactionConfig config,
 String txType,
 ApiTelemetryWork apiTelemetryWork,
 Observation parentObservation)

runTransaction

protected <T> org.reactivestreams.Publisher<T> runTransaction(AccessMode mode,
 Function<S,? extends org.reactivestreams.Publisher<T>> work,
 TransactionConfig config,
 Class<? extends BaseSession> sessionType,
 DriverObservationProvider observationProvider)

lastBookmarks

public Set<Bookmark> lastBookmarks()

run

protected <T> org.reactivestreams.Publisher<T> run(Query query,
 TransactionConfig config,
 Function<RxResultCursor,T> cursorToResult,
 Observation parentObservation)

doClose

protected <T> org.reactivestreams.Publisher<T> doClose(Observation parentObservation)