org.yamcs.client.base

Class ResponseObserver<T>

java.lang.Object

org.yamcs.client.base.ResponseObserver<T>

All Implemented Interfaces:

Observer<T>

public class ResponseObserver<T>
extends Object
implements Observer<T>

An observer that completes a future based on a single response.

Constructor Summary

Constructors

Constructor and Description
ResponseObserver(CompletableFuture<T> future)

Method Summary

Modifier and Type	Method and Description
void	complete()
void	completeExceptionally(Throwable t)
void	next(T message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.api.Observer

complete, isCancelled, setCancelHandler

Constructor Detail

ResponseObserver

public ResponseObserver(CompletableFuture<T> future)

Method Detail

next

public void next(T message)

Specified by:

next in interface Observer<T>

completeExceptionally

public void completeExceptionally(Throwable t)

Specified by:

completeExceptionally in interface Observer<T>

complete

public void complete()

Specified by:

complete in interface Observer<T>