Module org.yamcs.core

Package org.yamcs.http

Class ServerStreamingObserver

java.lang.Object

org.yamcs.http.ServerStreamingObserver

All Implemented Interfaces:

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

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

A message observer that implements a streaming response over HTTP using chunked transfer encoding.

Field Summary

Fields

Modifier and Type	Field	Description
protected io.netty.buffer.ByteBufOutputStream	bufOut

Constructor Summary

Constructors

Constructor	Description
ServerStreamingObserver(RouteContext 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

Field Details

bufOut

protected io.netty.buffer.ByteBufOutputStream bufOut

Constructor Details

ServerStreamingObserver

public ServerStreamingObserver(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>

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>