Class ClientStreamingObserver

java.lang.Object
org.yamcs.client.base.ClientStreamingObserver
All Implemented Interfaces:
Observer<com.google.protobuf.Message>

public class ClientStreamingObserver extends Object implements Observer<com.google.protobuf.Message>
A message observer that implements a streaming request over HTTP using chunked transfer encoding.
  • Constructor Details

    • ClientStreamingObserver

      public ClientStreamingObserver(com.google.protobuf.Descriptors.MethodDescriptor method, RestClient baseClient, com.google.protobuf.Message responsePrototype, Observer<com.google.protobuf.Message> responseObserver)
  • 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>