Searched refs:gzipSink (Results 1 – 6 of 6) sorted by relevance
32 GzipSink gzipSink = new GzipSink(sink); in gzipGunzip() local33 gzipSink.write(data, data.size()); in gzipGunzip()34 gzipSink.close(); in gzipGunzip()43 GzipSink gzipSink = new GzipSink(mockSink); in closeWithExceptionWhenWritingAndClosing() local44 gzipSink.write(new Buffer().writeUtf8(repeat("a", SEGMENT_SIZE)), SEGMENT_SIZE); in closeWithExceptionWhenWritingAndClosing()46 gzipSink.close(); in closeWithExceptionWhenWritingAndClosing()
76 @Test public void gzipSink() throws Exception { in gzipSink() method in LargeStreamsTest79 GzipSink gzipSink = new GzipSink(pipe.sink()); in gzipSink() local82 gzipSink.deflater().setLevel(Deflater.NO_COMPRESSION); in gzipSink()83 Future<Long> future = readAllAndCloseAsync(randomSource(FOUR_GIB_PLUS_ONE), gzipSink); in gzipSink()
31 GzipSink gzipSink = new GzipSink(sink); in gzipGunzip() local32 gzipSink.write(data, data.size()); in gzipGunzip()33 gzipSink.close(); in gzipGunzip()42 GzipSink gzipSink = new GzipSink(mockSink); in closeWithExceptionWhenWritingAndClosing() local43 gzipSink.write(new Buffer().writeUtf8(repeat('a', Segment.SIZE)), Segment.SIZE); in closeWithExceptionWhenWritingAndClosing()45 gzipSink.close(); in closeWithExceptionWhenWritingAndClosing()
93 BufferedSink gzipSink = Okio.buffer(new GzipSink(sink)); in gzip() local94 body.writeTo(gzipSink); in gzip()95 gzipSink.close(); in gzip()
189 GzipSink gzipSink = new GzipSink(gzipBody); in newResponse() local190 gzipSink.write(body, body.size()); in newResponse()191 gzipSink.close(); in newResponse()
3299 BufferedSink gzipSink = Okio.buffer(new GzipSink(result));3300 gzipSink.writeUtf8(data);3301 gzipSink.close();