@Test public void startFailsOnNullListener() { AbstractClientStream stream = new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); thrown.expect(NullPointerException.class); stream.start(null); }
@Override public final void start(ClientStreamListener listener) { transportState().setListener(listener); if (!useGet) { abstractClientStreamSink().writeHeaders(headers, null); headers = null; } }
AbstractClientStream extends AbstractStream implements ClientStream, MessageFramer.Sink { @Override public final void start(ClientStreamListener listener) { transportState().setListener(listener); if (!useGet) { abstractClientStreamSink().writeHeaders(headers, null); headers = null; } } }
AbstractClientStream extends AbstractStream implements ClientStream, MessageFramer.Sink { @Override public final void start(ClientStreamListener listener) { transportState().setListener(listener); if (!useGet) { abstractClientStreamSink().writeHeaders(headers, null); headers = null; } } protected  AbstractClientStream(
      WritableBufferAllocator bufferAllocator,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      Metadata headers,
      CallOptions callOptions,
      boolean useGet); }
AbstractClientStream extends AbstractStream implements ClientStream, MessageFramer.Sink { @Override public final void start(ClientStreamListener listener) { transportState().setListener(listener); if (!useGet) { abstractClientStreamSink().writeHeaders(headers, null); headers = null; } } protected  AbstractClientStream(
      WritableBufferAllocator bufferAllocator,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      Metadata headers,
      CallOptions callOptions,
      boolean useGet); @Override void setDeadline(Deadline deadline); @Override void setMaxOutboundMessageSize(int maxSize); @Override void setMaxInboundMessageSize(int maxSize); @Override final void setFullStreamDecompression(boolean fullStreamDecompression); @Override final void setDecompressorRegistry(DecompressorRegistry decompressorRegistry); @Override final void start(ClientStreamListener listener); final boolean shouldBeCountedForInUse(); @Override final void request(int numMessages); @Override final void deliverFrame(
      WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); @Override final void halfClose(); @Override final void cancel(Status reason); @Override final boolean isReady(); }
AbstractClientStream extends AbstractStream implements ClientStream, MessageFramer.Sink { @Override public final void start(ClientStreamListener listener) { transportState().setListener(listener); if (!useGet) { abstractClientStreamSink().writeHeaders(headers, null); headers = null; } } protected  AbstractClientStream(
      WritableBufferAllocator bufferAllocator,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      Metadata headers,
      CallOptions callOptions,
      boolean useGet); @Override void setDeadline(Deadline deadline); @Override void setMaxOutboundMessageSize(int maxSize); @Override void setMaxInboundMessageSize(int maxSize); @Override final void setFullStreamDecompression(boolean fullStreamDecompression); @Override final void setDecompressorRegistry(DecompressorRegistry decompressorRegistry); @Override final void start(ClientStreamListener listener); final boolean shouldBeCountedForInUse(); @Override final void request(int numMessages); @Override final void deliverFrame(
      WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); @Override final void halfClose(); @Override final void cancel(Status reason); @Override final boolean isReady();  }