class FailingClientStream extends NoopClientStream {

  @Override
  public void start(ClientStreamListener listener) {
    Preconditions.checkState(!started, "already started");
    started = true;
    listener.closed(error, rpcProgress, new Metadata());
  }

  public  FailingClientStream(Status error);
  public  FailingClientStream(Status error, RpcProgress rpcProgress);

}