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, InternalRxSession

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)
protected abstract S	createTransaction(UnmanagedTransaction unmanagedTransaction)
protected org.reactivestreams.Publisher<S>	doBeginTransaction(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork)
protected <T> org.reactivestreams.Publisher<T>	doClose()
Set<Bookmark>	lastBookmarks()
protected <T> org.reactivestreams.Publisher<T>	run(Query query, TransactionConfig config, Function<RxResultCursor,T> cursorToResult)
protected <T> org.reactivestreams.Publisher<T>	runTransaction(AccessMode mode, Function<S,? extends org.reactivestreams.Publisher<T>> work, TransactionConfig config)

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)

doBeginTransaction

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

runTransaction

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

lastBookmarks

public Set<Bookmark> lastBookmarks()

run

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

doClose

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