Lines Matching refs:Sink
23 public final Sink sink;
26 public RealBufferedSink(Sink sink, OkBuffer buffer) {
27 if (sink == null) throw new IllegalArgumentException("sink == null");
29 this.sink = sink;
32 public RealBufferedSink(Sink sink) {
33 this(sink, new OkBuffer());
116 if (byteCount > 0) sink.write(buffer, byteCount);
154 sink.write(buffer, buffer.size);
156 sink.flush();
162 // Emit buffered data to the underlying sink. If this fails, we still need
163 // to close the sink; otherwise we risk leaking resources.
167 sink.write(buffer, buffer.size);
174 sink.close();
183 @Override public Sink deadline(Deadline deadline) {
184 sink.deadline(deadline);
189 return "buffer(" + sink + ")";
