Uses of Interface
com.ocient.transport.TransportResult

Packages that use TransportResult

Package	Description
com.ocient.jdbc
com.ocient.transport
com.ocient.util

Uses of TransportResult in com.ocient.jdbc

Methods in com.ocient.jdbc that return types with arguments of type TransportResult

Modifier and Type	Method	Description
protected com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>>	XGConnection.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<ClientWireProtocol.Request>> requests, int queueDepth)	Exposes a streaming interface that allows the consumer to apply backpressure.

Uses of TransportResult in com.ocient.transport

Classes in com.ocient.transport that implement TransportResult

Modifier and Type	Class	Description
static class	TransportResult.FailedTransportResult<T>
static class	TransportResult.SuccessTransportResult<T>

Fields in com.ocient.transport declared as TransportResult

Modifier and Type	Field	Description
static final TransportResult<?>	TransportResult.VOID_TRANSPORT_RESULT

Fields in com.ocient.transport with type parameters of type TransportResult

Modifier and Type	Field	Description
static final CompletionStage<? extends TransportResult<?>>	TransportResult.VOID_TRANSPORT_RESULT_FUTURE

Methods in com.ocient.transport that return TransportResult

Modifier and Type	Method	Description
static <T> TransportResult<T>	TransportResult.fail(TransportException e)	Creates a new instance of TransportResult that represents a failed I/O operation.
static <T> TransportResult<T>	TransportResult.failOrMarshal(Throwable throwable)	Returns a new Result object that represents a failed operation with the given IOException.
static <T> TransportResult<T>	TransportResult.failRecv(Throwable e)	Creates a new instance of TransportResult that represents a failed send operation.
static <T> TransportResult<T>	TransportResult.failSend(Throwable e)	Creates a new instance of TransportResult that represents a failed send operation.
default <U> TransportResult<U>	TransportResult.flatMapSuccess(Function<? super T,? extends TransportResult<U>> fn)	Maps the success value of this TransportResult to the TransportResult type returned from the given function.
default <U> TransportResult<U>	TransportResult.mapSuccess(Function<? super T,? extends U> fn)
static <T> TransportResult<T>	TransportResult.success(T item)	Creates a new instance of TransportResult that represents a successful I/O operation.
static TransportResult<Void>	TransportResult.voidResult()	Returns an TransportResult that represents a successful execution of a I/O operation that does not produce a result.

Methods in com.ocient.transport that return types with arguments of type TransportResult

Modifier and Type	Method	Description
CompletionStage<TransportResult<JavaNetOcientWireV1Transport>>	JavaNetOcientWireV1Transport.Factory.connect(String host, int port, XGConnection.Tls tls, int connectTimeout)
CompletionStage<TransportResult<NettyOcientWireV1Transport>>	NettyOcientWireV1Transport.Factory.connect(String host, int port, XGConnection.Tls tls, int connectTimeout)
CompletionStage<TransportResult<T>>	SimplexTransportFactory.connect(String host, int port, XGConnection.Tls tls, int connectTimeout)	Connects to a remote host using the specified transport and configuration.
static <T> CompletionStage<TransportResult<T>>	TransportResult.failAsync(TransportException e)	Creates a new completed stage that represents a failed execution of an I/O operation.
static <T> CompletionStage<TransportResult<T>>	TransportResult.failOrMarshalAsync(Throwable throwable)	Returns a new completed staged that represents a failed operation with the given IOException.
static <T> CompletionStage<TransportResult<T>>	TransportResult.failRecvAsync(TransportException e)	Creates a new completed stage that represents a failed execution of an I/O operation.
static <T> CompletionStage<TransportResult<T>>	TransportResult.failSendAsync(TransportException e)	Creates a new completed stage that represents a failed execution of an I/O operation.
default <U> CompletionStage<TransportResult<U>>	TransportResult.mapSuccessAsync(Function<? super T,? extends CompletionStage<TransportResult<U>>> fn)	Maps the success value of this Result to a new completed stage of a different TransportResult type by applying the given function.
CompletionStage<TransportResult<io.netty.buffer.ByteBuf>>	JavaNetOcientWireV1Transport.sendAndReceive(io.netty.buffer.ByteBuf request, SimplexTransport.Ctx ctx)
CompletionStage<TransportResult<io.netty.buffer.ByteBuf>>	NettyOcientWireV1Transport.sendAndReceive(io.netty.buffer.ByteBuf request, SimplexTransport.Ctx ctx)
CompletionStage<TransportResult<TRESPONSE>>	SimplexTransport.sendAndReceive(TREQUEST request, SimplexTransport.Ctx ctx)	Sends a SimplexTransport to the server and returns a CompletionStage that completes with the SimplexTransport from the server.
CompletionStage<TransportResult<Void>>	JavaNetOcientWireV1Transport.sendNoReceive(io.netty.buffer.ByteBuf request, SimplexTransport.Ctx ctx)
CompletionStage<TransportResult<Void>>	NettyOcientWireV1Transport.sendNoReceive(io.netty.buffer.ByteBuf request, SimplexTransport.Ctx ctx)
CompletionStage<TransportResult<Void>>	SimplexTransport.sendNoReceive(TREQUEST request, SimplexTransport.Ctx ctx)	Sends SimplexTransport to the server.
com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>>	NettyOcientWireV1Transport.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>> requests, int queueDepth)
default com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<TRESPONSE>>>	SimplexTransport.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<TREQUEST>>> requests, int maxQueueDepth)	Accepts a stream of requests and returns the result response stream.
static <T> CompletionStage<TransportResult<T>>	TransportResult.successAsync(T item)	Creates a new completed stage that represents a successful execution of an I/O operation.
static CompletionStage<TransportResult<Void>>	TransportResult.voidFuture()	Returns a CompletionStage instance that completes successfully with a CompletableFutures.SQLResult that represents a successful execution of a I/O operation that does not produce a result.

Method parameters in com.ocient.transport with type arguments of type TransportResult

Modifier and Type	Method	Description
default <U> TransportResult<U>	TransportResult.flatMapSuccess(Function<? super T,? extends TransportResult<U>> fn)	Maps the success value of this TransportResult to the TransportResult type returned from the given function.
default <U> CompletionStage<TransportResult<U>>	TransportResult.mapSuccessAsync(Function<? super T,? extends CompletionStage<TransportResult<U>>> fn)	Maps the success value of this Result to a new completed stage of a different TransportResult type by applying the given function.
com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>>	NettyOcientWireV1Transport.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>> requests, int queueDepth)
default com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<TRESPONSE>>>	SimplexTransport.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<TREQUEST>>> requests, int maxQueueDepth)	Accepts a stream of requests and returns the result response stream.

Uses of TransportResult in com.ocient.util

Methods in com.ocient.util that return TransportResult

Modifier and Type	Method	Description
static <T> TransportResult<T>	CompletableFutures.blockingGetTransportResult(CompletionStage<TransportResult<T>> stage)	Blocks until the specified CompletionStage completes and returns its result as an TransportResult instance.

Methods in com.ocient.util that return types with arguments of type TransportResult

Modifier and Type	Method	Description
CompletionStage<TransportResult<SimplexTransport<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>>>	MockOcientCluster.connect(String host, int port, XGConnection.Tls tls, int connectTimeout)
CompletionStage<TransportResult<io.netty.buffer.ByteBuf>>	MockOcientCluster.Transport.sendAndReceive(io.netty.buffer.ByteBuf request, SimplexTransport.Ctx ctx)
CompletionStage<TransportResult<Void>>	MockOcientCluster.Transport.sendNoReceive(io.netty.buffer.ByteBuf request, SimplexTransport.Ctx ctx)
com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>>	MockOcientCluster.Transport.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>> requests, int maxQueueDepth)

Method parameters in com.ocient.util with type arguments of type TransportResult

Modifier and Type	Method	Description
static <T> TransportResult<T>	CompletableFutures.blockingGetTransportResult(CompletionStage<TransportResult<T>> stage)	Blocks until the specified CompletionStage completes and returns its result as an TransportResult instance.
com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>>	MockOcientCluster.Transport.stream(com.ibm.asyncutil.iteration.AsyncIterator<SimplexTransport.StreamCtx<TransportResult<io.netty.buffer.ByteBuf>>> requests, int maxQueueDepth)