@Test public void writeHeaders_failsOnNullHeaders() { AbstractServerStreamBase stream = new AbstractServerStreamBase(allocator, MAX_MESSAGE_SIZE); thrown.expect(NullPointerException.class); stream.writeHeaders(null); }
@Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); outboundPhase(Phase.HEADERS); headersSent = true; internalSendHeaders(headers); outboundPhase(Phase.MESSAGE); }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); outboundPhase(Phase.HEADERS); headersSent = true; internalSendHeaders(headers); outboundPhase(Phase.MESSAGE); } }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); outboundPhase(Phase.HEADERS); headersSent = true; internalSendHeaders(headers); outboundPhase(Phase.MESSAGE); } protected  AbstractServerStream(WritableBufferAllocator bufferAllocator,
                                 int maxMessageSize); }
AbstractServerStream extends AbstractStream<IdT> implements ServerStream { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); outboundPhase(Phase.HEADERS); headersSent = true; internalSendHeaders(headers); outboundPhase(Phase.MESSAGE); } 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 writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); outboundPhase(Phase.HEADERS); headersSent = true; internalSendHeaders(headers); outboundPhase(Phase.MESSAGE); } 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();  }