Package org.yamcs.http
Class ServerStreamingObserver
java.lang.Object
org.yamcs.http.ServerStreamingObserver
- All Implemented Interfaces:
Observer<com.google.protobuf.Message>
public class ServerStreamingObserver
extends Object
implements Observer<com.google.protobuf.Message>
A message observer that implements a streaming response over HTTP using chunked transfer encoding.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
complete()
Mark the successful end.void
Complete with an exception.boolean
Returns whether this call has been cancelled by the remote peervoid
next
(com.google.protobuf.Message message) Emit the next message.void
setCancelHandler
(Runnable cancelHandler) Set aRunnable
that will be called when the call is cancelled.
-
Field Details
-
bufOut
protected io.netty.buffer.ByteBufOutputStream bufOut
-
-
Constructor Details
-
ServerStreamingObserver
-
-
Method Details
-
next
public void next(com.google.protobuf.Message message) Description copied from interface:Observer
Emit the next message. -
completeExceptionally
Description copied from interface:Observer
Complete with an exception.- Specified by:
completeExceptionally
in interfaceObserver<com.google.protobuf.Message>
-
complete
public void complete()Description copied from interface:Observer
Mark the successful end. -
isCancelled
public boolean isCancelled()Description copied from interface:Observer
Returns whether this call has been cancelled by the remote peer- Specified by:
isCancelled
in interfaceObserver<com.google.protobuf.Message>
-
setCancelHandler
Description copied from interface:Observer
Set aRunnable
that will be called when the call is cancelled. (example: peer disconnect)- Specified by:
setCancelHandler
in interfaceObserver<com.google.protobuf.Message>
-