Class SessionCloseableObserver<T>

java.lang.Object
io.deephaven.server.session.SessionCloseableObserver<T>
All Implemented Interfaces:
Closeable, AutoCloseable
Direct Known Subclasses:
JavaAutoCompleteObserver, PythonAutoCompleteObserver

public abstract class SessionCloseableObserver<T> extends Object implements Closeable
  • Field Details

    • session

      protected final SessionState session
    • responseObserver

      protected final io.grpc.stub.StreamObserver<T> responseObserver
  • Constructor Details

    • SessionCloseableObserver

      public SessionCloseableObserver(SessionState session, io.grpc.stub.StreamObserver<T> responseObserver)
  • Method Details

    • close

      public final void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
    • onClose

      protected void onClose()
      Override this to perform any additional specific clean up that must be performed.