| Constructor and Description |
|---|
RetryableSink() |
RetryableSink(int limit) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Pushes all buffered bytes to their final destination and releases the
resources held by this sink.
|
long |
contentLength() |
void |
flush()
Pushes all buffered bytes to their final destination.
|
Timeout |
timeout()
Returns the timeout for this sink.
|
void |
write(Buffer source,
long byteCount)
Removes
byteCount bytes from source and appends them to this. |
void |
writeToSocket(Sink socketOut) |
public RetryableSink(int limit)
public RetryableSink()
public void close()
throws IOException
Sinkclose in interface Closeableclose in interface AutoCloseableclose in interface SinkIOExceptionpublic void write(Buffer source, long byteCount) throws IOException
SinkbyteCount bytes from source and appends them to this.write in interface SinkIOExceptionpublic void flush()
throws IOException
Sinkflush in interface Flushableflush in interface SinkIOException - if there are any issues writing the data.public Timeout timeout()
Sinkpublic long contentLength()
throws IOException
IOExceptionpublic void writeToSocket(Sink socketOut) throws IOException
IOException