Module org.yamcs.core

Package org.yamcs.http.api

Class SubscribeEventsObserver

java.lang.Object

org.yamcs.http.api.SubscribeEventsObserver

All Implemented Interfaces:

org.yamcs.api.Observer<org.yamcs.protobuf.SubscribeEventsRequest>, StreamSubscriber

public class SubscribeEventsObserver
extends Object
implements org.yamcs.api.Observer<org.yamcs.protobuf.SubscribeEventsRequest>, StreamSubscriber

Constructor Summary

Constructors

Constructor	Description
SubscribeEventsObserver(org.yamcs.api.Observer<org.yamcs.protobuf.Event> responseObserver)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	completeExceptionally(Throwable t)
void	next(org.yamcs.protobuf.SubscribeEventsRequest request)
void	onTuple(Stream stream, Tuple tuple)
void	streamClosed(Stream stream)

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

SubscribeEventsObserver

public SubscribeEventsObserver(org.yamcs.api.Observer<org.yamcs.protobuf.Event> responseObserver)

Method Details

next

public void next(org.yamcs.protobuf.SubscribeEventsRequest request)

Specified by:

next in interface org.yamcs.api.Observer<org.yamcs.protobuf.SubscribeEventsRequest>

onTuple

public void onTuple(Stream stream,
 Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber

completeExceptionally

public void completeExceptionally(Throwable t)

Specified by:

completeExceptionally in interface org.yamcs.api.Observer<org.yamcs.protobuf.SubscribeEventsRequest>

complete

public void complete()

Specified by:

complete in interface org.yamcs.api.Observer<org.yamcs.protobuf.SubscribeEventsRequest>