Lines Matching defs:sink
31 * <p>Use {@link #sink} and {@link #source} to apply this timeout to a stream.
145 * Returns a new sink that delegates to {@code sink}, using this to implement
147 * {@code sink}'s current operation.
149 public final Sink sink(final Sink sink) {
150 return new Sink() {
155 sink.write(source, byteCount);
168 sink.flush();
181 sink.close();
195 return "AsyncTimeout.sink(" + sink + ")";
203 * interrupt {@code sink}'s current operation.
207 @Override public long read(Buffer sink, long byteCount) throws IOException {
211 long result = source.read(sink, byteCount);
