@Test public void writeHeaders_failsOnNullHeaders() { thrown.expect(NullPointerException.class); stream.writeHeaders(null); }
@Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); headersSent = true; abstractServerStreamSink().writeHeaders(headers); }
AbstractServerStream extends AbstractStream implements ServerStream, MessageFramer.Sink { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); headersSent = true; abstractServerStreamSink().writeHeaders(headers); } }
AbstractServerStream extends AbstractStream implements ServerStream, MessageFramer.Sink { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); headersSent = true; abstractServerStreamSink().writeHeaders(headers); } protected  AbstractServerStream(
      WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx); }
AbstractServerStream extends AbstractStream implements ServerStream, MessageFramer.Sink { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); headersSent = true; abstractServerStreamSink().writeHeaders(headers); } protected  AbstractServerStream(
      WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx); @Override final void request(int numMessages); @Override final void writeHeaders(Metadata headers); @Override final void deliverFrame(
      WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); @Override final void close(Status status, Metadata trailers); @Override final void cancel(Status status); @Override final boolean isReady(); @Override final void setDecompressor(Decompressor decompressor); @Override Attributes getAttributes(); @Override String getAuthority(); @Override final void setListener(ServerStreamListener serverStreamListener); @Override StatsTraceContext statsTraceContext(); }
AbstractServerStream extends AbstractStream implements ServerStream, MessageFramer.Sink { @Override public final void writeHeaders(Metadata headers) { Preconditions.checkNotNull(headers, "headers"); headersSent = true; abstractServerStreamSink().writeHeaders(headers); } protected  AbstractServerStream(
      WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx); @Override final void request(int numMessages); @Override final void writeHeaders(Metadata headers); @Override final void deliverFrame(
      WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); @Override final void close(Status status, Metadata trailers); @Override final void cancel(Status status); @Override final boolean isReady(); @Override final void setDecompressor(Decompressor decompressor); @Override Attributes getAttributes(); @Override String getAuthority(); @Override final void setListener(ServerStreamListener serverStreamListener); @Override StatsTraceContext statsTraceContext();  }