Module org.yamcs.core

Package org.yamcs.http

Class CallObserver

java.lang.Object

org.yamcs.http.CallObserver

All Implemented Interfaces:

org.yamcs.api.Observer<com.google.protobuf.Message>

public class CallObserver
extends Object
implements org.yamcs.api.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()
void	completeExceptionally(Throwable t)
void	next(com.google.protobuf.Message 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)

Specified by:

next in interface org.yamcs.api.Observer<com.google.protobuf.Message>

completeExceptionally

public void completeExceptionally(Throwable t)

Specified by:

completeExceptionally in interface org.yamcs.api.Observer<com.google.protobuf.Message>

complete

public void complete()

Specified by:

complete in interface org.yamcs.api.Observer<com.google.protobuf.Message>