Module org.yamcs.core

Package org.yamcs.http

Class WebSocketObserver

java.lang.Object

org.yamcs.http.WebSocketObserver

All Implemented Interfaces:

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

public class WebSocketObserver
extends Object
implements org.yamcs.api.Observer<com.google.protobuf.Message>

Constructor Summary

Constructors

Constructor	Description
WebSocketObserver(TopicContext ctx)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	completeExceptionally(Throwable t)
boolean	isCancelled()
void	next(com.google.protobuf.Message message)
void	setCancelHandler(Runnable cancelHandler)

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

Constructor Details

WebSocketObserver

public WebSocketObserver(TopicContext 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>

isCancelled

public boolean isCancelled()

Specified by:

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

setCancelHandler

public void setCancelHandler(Runnable cancelHandler)

Specified by:

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