@Test public void close_failsOnNullStatus() { thrown.expect(NullPointerException.class); defaultStream.close(null, new Metadata()); }
@Override public final void close(Status status, Metadata trailers) { Preconditions.checkNotNull(status, "status"); Preconditions.checkNotNull(trailers, "trailers"); if (outboundPhase(Phase.STATUS) != Phase.STATUS) { gracefulClose = true; stashedTrailers = trailers; writeStatusToTrailers(status); closeFramer(); } }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void close(Status status, Metadata trailers) { Preconditions.checkNotNull(status, "status"); Preconditions.checkNotNull(trailers, "trailers"); if (outboundPhase(Phase.STATUS) != Phase.STATUS) { gracefulClose = true; stashedTrailers = trailers; writeStatusToTrailers(status); closeFramer(); } } }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void close(Status status, Metadata trailers) { Preconditions.checkNotNull(status, "status"); Preconditions.checkNotNull(trailers, "trailers"); if (outboundPhase(Phase.STATUS) != Phase.STATUS) { gracefulClose = true; stashedTrailers = trailers; writeStatusToTrailers(status); closeFramer(); } } protected  AbstractServerStream(WritableBufferAllocator bufferAllocator,
                                 int maxMessageSize); }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void close(Status status, Metadata trailers) { Preconditions.checkNotNull(status, "status"); Preconditions.checkNotNull(trailers, "trailers"); if (outboundPhase(Phase.STATUS) != Phase.STATUS) { gracefulClose = true; stashedTrailers = trailers; writeStatusToTrailers(status); closeFramer(); } } protected  AbstractServerStream(WritableBufferAllocator bufferAllocator,
                                 int maxMessageSize); final void setListener(ServerStreamListener listener); @Override final void writeHeaders(Metadata headers); @Override final void writeMessage(InputStream message); @Override final void close(Status status, Metadata trailers); void inboundDataReceived(ReadableBuffer frame, boolean endOfStream); void complete(); final void abortStream(Status status, boolean notifyClient); @Override boolean isClosed(); @Override Attributes attributes(); }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void close(Status status, Metadata trailers) { Preconditions.checkNotNull(status, "status"); Preconditions.checkNotNull(trailers, "trailers"); if (outboundPhase(Phase.STATUS) != Phase.STATUS) { gracefulClose = true; stashedTrailers = trailers; writeStatusToTrailers(status); closeFramer(); } } protected  AbstractServerStream(WritableBufferAllocator bufferAllocator,
                                 int maxMessageSize); final void setListener(ServerStreamListener listener); @Override final void writeHeaders(Metadata headers); @Override final void writeMessage(InputStream message); @Override final void close(Status status, Metadata trailers); void inboundDataReceived(ReadableBuffer frame, boolean endOfStream); void complete(); final void abortStream(Status status, boolean notifyClient); @Override boolean isClosed(); @Override Attributes attributes();  }