@Test public void close() throws Exception { mStream.close(); assertTrue(mStream.isClosed()); assertFalse(mStream.isOpen()); verify(mRequestObserver).onCompleted(); }
public void close() { if (isOpen()) { LOG.debug("Closing stream ({})", mDescription); mClosed = true; mRequestObserver.onCompleted(); } }
GrpcBlockingStream { public void close() { if (isOpen()) { LOG.debug("Closing stream ({})", mDescription); mClosed = true; mRequestObserver.onCompleted(); } } }
GrpcBlockingStream { public void close() { if (isOpen()) { LOG.debug("Closing stream ({})", mDescription); mClosed = true; mRequestObserver.onCompleted(); } } GrpcBlockingStream(Function<StreamObserver<ResT>, StreamObserver<ReqT>> rpcFunc,
      int bufferSize, String description); }
GrpcBlockingStream { public void close() { if (isOpen()) { LOG.debug("Closing stream ({})", mDescription); mClosed = true; mRequestObserver.onCompleted(); } } GrpcBlockingStream(Function<StreamObserver<ResT>, StreamObserver<ReqT>> rpcFunc,
      int bufferSize, String description); void send(ReqT request, long timeoutMs); void send(ReqT request); ResT receive(long timeoutMs); void close(); void cancel(); void waitForComplete(long timeoutMs); boolean isClosedFromRemote(); boolean isOpen(); boolean isClosed(); boolean isCanceled(); }
GrpcBlockingStream { public void close() { if (isOpen()) { LOG.debug("Closing stream ({})", mDescription); mClosed = true; mRequestObserver.onCompleted(); } } GrpcBlockingStream(Function<StreamObserver<ResT>, StreamObserver<ReqT>> rpcFunc,
      int bufferSize, String description); void send(ReqT request, long timeoutMs); void send(ReqT request); ResT receive(long timeoutMs); void close(); void cancel(); void waitForComplete(long timeoutMs); boolean isClosedFromRemote(); boolean isOpen(); boolean isClosed(); boolean isCanceled();  }