Package io.deephaven.server.arrow

Interface ExchangeMarshaller.Subscription

Enclosing interface:
ExchangeMarshaller
public static interface ExchangeMarshaller.Subscription
The return value from a ExchangeMarshaller.subscribe(BarrageSubscriptionRequest, BarrageSubscriptionOptions, Object, StreamObserver) call.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Release the resources associated with this subscription.
    @Nullable LivenessReferent
    toManage()
     
    boolean
    update(io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest subscriptionRequest)
    Update the subscription with the new request.

  • Method Details

    • toManage

      @Nullable @Nullable LivenessReferent toManage()
      Returns:
      an object that should be managed for this subscription, or null

    • close

      void close()
      Release the resources associated with this subscription.

    • update

      boolean update(io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest subscriptionRequest)
      Update the subscription with the new request.
      Parameters:
      subscriptionRequest - the request to update the subscription
      Returns:
      true if the subscription was found and updated, false otherwise