Package org.yamcs.http

Class CallObserver

java.lang.Object

org.yamcs.http.CallObserver

All Implemented Interfaces:

Observer<com.google.protobuf.Message>

public class CallObserver
extends Object
implements Observer<com.google.protobuf.Message>

Observes the state of a single RPC call where both request and response are non-streaming.

Constructor Summary

Constructors

Constructor	Description
CallObserver(RouteContext ctx)

Method Summary

Modifier and Type	Method	Description
void	complete()	Mark the successful end.
void	completeExceptionally(Throwable t)	Complete with an exception.
void	next(com.google.protobuf.Message message)	Emit the next 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 Details

CallObserver

public CallObserver(RouteContext ctx)

Method Details

next

public void next(com.google.protobuf.Message message)

Description copied from interface: Observer

Emit the next message.

Specified by:

next in interface Observer<com.google.protobuf.Message>

completeExceptionally

public void completeExceptionally(Throwable t)

Description copied from interface: Observer

Complete with an exception.

Specified by:

completeExceptionally in interface Observer<com.google.protobuf.Message>

complete

public void complete()

Description copied from interface: Observer

Mark the successful end.

Specified by:

complete in interface Observer<com.google.protobuf.Message>