Package io.deephaven.server.session

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 Summary

Fields

Modifier and Type	Field	Description
protected final io.grpc.stub.StreamObserver<T>	responseObserver
protected final SessionState	session

Constructor Summary

Constructors

Constructor	Description
SessionCloseableObserver(SessionState session, io.grpc.stub.StreamObserver<T> responseObserver)

Method Summary

Modifier and Type	Method	Description
final void	close()
protected void	onClose()	Override this to perform any additional specific clean up that must be performed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.