FutureStreamObserver (AxonServer Connector 2026.0.0 API)

java.lang.Object
- java.util.concurrent.CompletableFuture<T>
- - io.axoniq.axonserver.connector.impl.FutureStreamObserver<T>

Type Parameters:

T - the type of result this CompletableFuture and StreamObserver resolves

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>, CompletionStage<T>, Future<T>
```
public class FutureStreamObserver<T>
extends CompletableFuture<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).

Nested Class Summary
- Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture
  CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors
Constructor	Description
`FutureStreamObserver(Throwable valueWhenNoResult)`	Construct a `FutureStreamObserver`, using the given `valueWhenNoResult` if no result is returned.
`FutureStreamObserver(T valueWhenNoResult)`	Construct a `FutureStreamObserver`, using the given `valueWhenNoResult` if no result is returned.

Method Summary

All Methods Instance Methods Concrete Methods
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
  - FutureStreamObserver
```
public FutureStreamObserver(T valueWhenNoResult)
```
    Construct a FutureStreamObserver, using the given valueWhenNoResult if no result is returned.
    
    Parameters:
    
    valueWhenNoResult - the object of type T to return if nothing is returned by this StreamObserver
  - FutureStreamObserver
```
public FutureStreamObserver(Throwable valueWhenNoResult)
```
    Construct a FutureStreamObserver, using the given valueWhenNoResult if no result is returned. This future will complete exceptionally when the valueWhenNoResult is used.
    
    Parameters:
    
    valueWhenNoResult - the Throwable to return if nothing is returned by this StreamObserver
- 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>