Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.impl

Class FutureListStreamObserver<T>

java.lang.Object

java.util.concurrent.CompletableFuture<List<T>>

io.axoniq.axonserver.connector.impl.FutureListStreamObserver<T>

Type Parameters:

T - the type of result this CompletableFuture and StreamObserver resolves

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>, CompletionStage<List<T>>, Future<List<T>>

public class FutureListStreamObserver<T>
extends CompletableFuture<List<T>>
implements io.grpc.stub.StreamObserver<T>

An implementation of both a CompletableFuture and StreamObserver. This future will complete successfully on onNext(Object) or on onCompleted() (granted that the given valueWhenNoResult is not of type Throwable). On onError(Throwable), this future will CompletableFuture.completeExceptionally(Throwable).

Since:

4.6.0

Author:

Stefan Dragisic

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
FutureListStreamObserver()

Method Summary

Modifier and Type	Method	Description
void	onCompleted()
void	onError(Throwable t)
void	onNext(T value)

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureListStreamObserver

public FutureListStreamObserver()

Method Detail

onNext

public void onNext(T value)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<T>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<T>