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 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)
      Description copied from interface: Observer
      Emit the next message.
      Specified by:
      next in interface Observer<com.google.protobuf.Message>
    • completeExceptionally

      public void completeExceptionally(Throwable t)
      Description copied from interface: Observer
      Complete with an exception.
      Specified by:
      completeExceptionally in interface Observer<com.google.protobuf.Message>
    • complete

      public void complete()
      Description copied from interface: Observer
      Mark the successful end.
      Specified by:
      complete in interface Observer<com.google.protobuf.Message>
    • isCancelled

      public boolean isCancelled()
      Description copied from interface: Observer
      Returns whether this call has been cancelled by the remote peer
      Specified by:
      isCancelled in interface Observer<com.google.protobuf.Message>
    • setCancelHandler

      public void setCancelHandler(Runnable cancelHandler)
      Description copied from interface: Observer
      Set a Runnable that will be called when the call is cancelled. (example: peer disconnect)
      Specified by:
      setCancelHandler in interface Observer<com.google.protobuf.Message>