diff --git a/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/MockWebServer.java b/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/MockWebServer.java
index 8604856169d0..a9cc4ffb7678 100644
--- a/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/MockWebServer.java
+++ b/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/MockWebServer.java
@@ -717,7 +717,7 @@ private void writeResponse(SpdyStream stream, MockResponse response) throws IOEx
         }
         BufferedSink sink = Okio.buffer(stream.getSink());
         if (response.getThrottleBytesPerPeriod() == Integer.MAX_VALUE) {
-          sink.write(body, body.size());
+          sink.writeAll(body);
           sink.flush();
         } else {
           while (body.size() > 0) {
diff --git a/okcurl/src/test/java/com/squareup/okhttp/curl/MainTest.java b/okcurl/src/test/java/com/squareup/okhttp/curl/MainTest.java
index d7fdffd0babe..48655787a2de 100644
--- a/okcurl/src/test/java/com/squareup/okhttp/curl/MainTest.java
+++ b/okcurl/src/test/java/com/squareup/okhttp/curl/MainTest.java
@@ -87,8 +87,7 @@ private static String bodyAsString(Request.Body body) {
     try {
       Buffer buffer = new Buffer();
       body.writeTo(buffer);
-      return new String(buffer.readByteString(buffer.size()).toByteArray(),
-          body.contentType().charset());
+      return buffer.readString(body.contentType().charset());
     } catch (IOException e) {
       throw new RuntimeException(e);
     }
diff --git a/okhttp-apache/src/test/java/com/squareup/okhttp/apache/OkApacheClientTest.java b/okhttp-apache/src/test/java/com/squareup/okhttp/apache/OkApacheClientTest.java
index 5590e01fbce2..5ebc35bf2622 100644
--- a/okhttp-apache/src/test/java/com/squareup/okhttp/apache/OkApacheClientTest.java
+++ b/okhttp-apache/src/test/java/com/squareup/okhttp/apache/OkApacheClientTest.java
@@ -233,6 +233,6 @@ private static String gunzip(HttpEntity body) throws IOException {
     while ((read = in.read(temp)) != -1) {
       buffer.write(temp, 0, read);
     }
-    return buffer.readUtf8(buffer.size());
+    return buffer.readUtf8();
   }
 }
diff --git a/okhttp-tests/src/test/java/com/squareup/okhttp/RecordingCallback.java b/okhttp-tests/src/test/java/com/squareup/okhttp/RecordingCallback.java
index ddb27a67a87a..6da0db00c375 100644
--- a/okhttp-tests/src/test/java/com/squareup/okhttp/RecordingCallback.java
+++ b/okhttp-tests/src/test/java/com/squareup/okhttp/RecordingCallback.java
@@ -41,8 +41,7 @@ public class RecordingCallback implements Response.Callback {
     Response.Body body = response.body();
     body.source().readAll(buffer);
 
-    responses.add(new RecordedResponse(
-        response.request(), response, buffer.readUtf8(buffer.size()), null));
+    responses.add(new RecordedResponse(response.request(), response, buffer.readUtf8(), null));
     notifyAll();
   }
 
diff --git a/okhttp-tests/src/test/java/com/squareup/okhttp/RequestTest.java b/okhttp-tests/src/test/java/com/squareup/okhttp/RequestTest.java
index d8870fcde16b..fcb26b1fa697 100644
--- a/okhttp-tests/src/test/java/com/squareup/okhttp/RequestTest.java
+++ b/okhttp-tests/src/test/java/com/squareup/okhttp/RequestTest.java
@@ -76,6 +76,6 @@ public final class RequestTest {
   private String bodyToHex(Request.Body body) throws IOException {
     Buffer buffer = new Buffer();
     body.writeTo(buffer);
-    return buffer.readByteString(buffer.size()).hex();
+    return buffer.readByteString().hex();
   }
 }
diff --git a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/HpackDraft06Test.java b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/HpackDraft06Test.java
index 79c36755be6c..8c17465a8ecf 100644
--- a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/HpackDraft06Test.java
+++ b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/HpackDraft06Test.java
@@ -53,7 +53,7 @@ public class HpackDraft06Test {
     List<Header> headerBlock = headerEntries("cookie", new String(value));
 
     hpackWriter.writeHeaders(headerBlock);
-    bytesIn.write(bytesOut, bytesOut.size());
+    bytesIn.writeAll(bytesOut);
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
 
@@ -76,7 +76,7 @@ public class HpackDraft06Test {
     out.writeByte(0x0d); // Literal value (len = 13)
     out.writeUtf8("custom-header");
 
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(out);
     hpackReader.maxHeaderTableByteCount(1);
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
@@ -111,7 +111,7 @@ public class HpackDraft06Test {
     out.writeByte(0x0d); // Literal value (len = 13)
     out.writeUtf8("custom-header");
 
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(out);
     // Set to only support 110 bytes (enough for 2 headers).
     hpackReader.maxHeaderTableByteCount(110);
     hpackReader.readHeaders();
@@ -150,7 +150,7 @@ public class HpackDraft06Test {
       out.writeUtf8("custom-header");
     }
 
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(out);
     hpackReader.maxHeaderTableByteCount(16384); // Lots of headers need more room!
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
@@ -173,7 +173,7 @@ public class HpackDraft06Test {
         (byte) 0x25, (byte) 0xba, (byte) 0x7f};
     out.write(huffmanBytes, 0, huffmanBytes.length);
 
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(out);
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
 
@@ -198,7 +198,7 @@ public class HpackDraft06Test {
     out.writeByte(0x0d); // Literal value (len = 13)
     out.writeUtf8("custom-header");
 
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(out);
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
 
@@ -230,7 +230,7 @@ public class HpackDraft06Test {
     hpackWriter.writeHeaders(headerBlock);
     assertEquals(expectedBytes, bytesOut);
 
-    bytesIn.write(bytesOut, bytesOut.size());
+    bytesIn.writeAll(bytesOut);
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
 
@@ -254,7 +254,7 @@ public class HpackDraft06Test {
     hpackWriter.writeHeaders(headerBlock);
     assertEquals(expectedBytes, bytesOut);
 
-    bytesIn.write(bytesOut, bytesOut.size());
+    bytesIn.writeAll(bytesOut);
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
 
@@ -431,20 +431,17 @@ public class HpackDraft06Test {
    * http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-06#appendix-D.2
    */
   @Test public void readRequestExamplesWithoutHuffman() throws IOException {
-    Buffer out = firstRequestWithoutHuffman();
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(firstRequestWithoutHuffman());
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
     checkReadFirstRequestWithoutHuffman();
 
-    out = secondRequestWithoutHuffman();
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(secondRequestWithoutHuffman());
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
     checkReadSecondRequestWithoutHuffman();
 
-    out = thirdRequestWithoutHuffman();
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(thirdRequestWithoutHuffman());
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
     checkReadThirdRequestWithoutHuffman();
@@ -634,20 +631,17 @@ private void checkReadThirdRequestWithoutHuffman() {
    * http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-06#appendix-D.3
    */
   @Test public void readRequestExamplesWithHuffman() throws IOException {
-    Buffer out = firstRequestWithHuffman();
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(firstRequestWithHuffman());
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
     checkReadFirstRequestWithHuffman();
 
-    out = secondRequestWithHuffman();
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(secondRequestWithHuffman());
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
     checkReadSecondRequestWithHuffman();
 
-    out = thirdRequestWithHuffman();
-    bytesIn.write(out, out.size());
+    bytesIn.writeAll(thirdRequestWithHuffman());
     hpackReader.readHeaders();
     hpackReader.emitReferenceSet();
     checkReadThirdRequestWithHuffman();
@@ -928,6 +922,7 @@ private void checkEntry(Header entry, String name, String value, int size) {
 
   private void assertBytes(int... bytes) {
     ByteString expected = intArrayToByteArray(bytes);
+    // TODO change to bytesOut.readByteString() once Okio 0.8.1+ is available.
     ByteString actual = bytesOut.readByteString(bytesOut.size());
     assertEquals(expected, actual);
   }
diff --git a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/Http20Draft10Test.java b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/Http20Draft10Test.java
index 319689292594..35fbb4f6ef8a 100644
--- a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/Http20Draft10Test.java
+++ b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/Http20Draft10Test.java
@@ -71,7 +71,7 @@ public class Http20Draft10Test {
       frame.writeByte(Http20Draft10.TYPE_HEADERS);
       frame.writeByte(FLAG_END_HEADERS | FLAG_END_STREAM);
       frame.writeInt(expectedStreamId & 0x7fffffff);
-      frame.write(headerBytes, headerBytes.size());
+      frame.writeAll(headerBytes);
     }
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -106,7 +106,7 @@ public void headers(boolean outFinished, boolean inFinished, int streamId,
       frame.writeByte(FLAG_END_HEADERS | FLAG_PRIORITY);
       frame.writeInt(expectedStreamId & 0x7fffffff);
       frame.writeInt(0); // Highest priority is 0.
-      frame.write(headerBytes, headerBytes.size());
+      frame.writeAll(headerBytes);
     }
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -149,7 +149,7 @@ public void headers(boolean outFinished, boolean inFinished, int streamId,
       frame.writeByte(Http20Draft10.TYPE_CONTINUATION);
       frame.writeByte(FLAG_END_HEADERS);
       frame.writeInt(expectedStreamId & 0x7fffffff);
-      frame.write(headerBlock, headerBlock.size());
+      frame.writeAll(headerBlock);
     }
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -191,7 +191,7 @@ public void headers(boolean outFinished, boolean inFinished, int streamId,
       frame.writeByte(Http20Draft10.FLAG_END_PUSH_PROMISE);
       frame.writeInt(expectedStreamId & 0x7fffffff);
       frame.writeInt(expectedPromisedStreamId & 0x7fffffff);
-      frame.write(headerBytes, headerBytes.size());
+      frame.writeAll(headerBytes);
     }
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -557,7 +557,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
     frame.writeByte(FLAG_END_HEADERS | FLAG_PAD_HIGH | FLAG_PAD_LOW);
     frame.writeInt(expectedStreamId & 0x7fffffff);
     frame.writeShort(paddingLength);
-    frame.write(headerBlock, headerBlock.size());
+    frame.writeAll(headerBlock);
     frame.write(padding);
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -574,7 +574,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
     frame.writeByte(FLAG_END_HEADERS | FLAG_PAD_HIGH | FLAG_PAD_LOW);
     frame.writeInt(expectedStreamId & 0x7fffffff);
     frame.writeShort(0);
-    frame.write(headerBlock, headerBlock.size());
+    frame.writeAll(headerBlock);
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
     fr.nextFrame(assertHeaderBlock());
@@ -589,7 +589,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
     frame.writeByte(FLAG_END_HEADERS | FLAG_PAD_LOW);
     frame.writeInt(expectedStreamId & 0x7fffffff);
     frame.writeByte(0);
-    frame.write(headerBlock, headerBlock.size());
+    frame.writeAll(headerBlock);
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
     fr.nextFrame(assertHeaderBlock());
@@ -608,7 +608,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
     frame.writeByte(FLAG_PAD_HIGH);
     frame.writeInt(expectedStreamId & 0x7fffffff);
     frame.writeShort(paddingLength);
-    frame.write(headerBlock, headerBlock.size());
+    frame.writeAll(headerBlock);
     frame.write(padding);
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -636,7 +636,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
     frame.writeByte(FLAG_PAD_HIGH | FLAG_PAD_LOW);
     frame.writeInt(expectedStreamId & 0x7fffffff);
     frame.writeShort(0xffff);
-    frame.write(headerBlock, headerBlock.size());
+    frame.writeAll(headerBlock);
     frame.write(padding);
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -676,7 +676,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
       frame.writeByte(FLAG_END_HEADERS | FLAG_PAD_HIGH | FLAG_PAD_LOW);
       frame.writeInt(expectedStreamId & 0x7fffffff);
       frame.writeShort(paddingLength);
-      frame.write(headerBlock, headerBlock.size());
+      frame.writeAll(headerBlock);
       frame.write(padding);
     }
 
@@ -703,7 +703,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
       frame.writeByte(FLAG_END_HEADERS | FLAG_PAD_HIGH | FLAG_PAD_LOW);
       frame.writeInt(expectedStreamId & 0x7fffffff);
       frame.writeShort(0);
-      frame.write(headerBlock, headerBlock.size());
+      frame.writeAll(headerBlock);
     }
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -728,7 +728,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
       frame.writeByte(FLAG_END_HEADERS | FLAG_PAD_LOW);
       frame.writeInt(expectedStreamId & 0x7fffffff);
       frame.writeByte(0);
-      frame.write(headerBlock, headerBlock.size());
+      frame.writeAll(headerBlock);
     }
 
     FrameReader fr = new Http20Draft10.Reader(frame, 4096, false);
@@ -757,7 +757,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
       frame.writeByte(FLAG_PAD_HIGH);
       frame.writeInt(expectedStreamId & 0x7fffffff);
       frame.writeShort(paddingLength);
-      frame.write(headerBlock, headerBlock.size());
+      frame.writeAll(headerBlock);
       frame.write(padding);
     }
 
@@ -807,7 +807,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> headerB
     } catch (IOException e) {
       assertEquals("PROTOCOL_ERROR padding > 16383: 65535", e.getMessage());
     }
-  }  
+  }
 
   @Test public void tooLargeDataFrame() throws IOException {
     try {
diff --git a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/MockSpdyPeer.java b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/MockSpdyPeer.java
index 5507c2d068ea..014684a831ff 100644
--- a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/MockSpdyPeer.java
+++ b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/MockSpdyPeer.java
@@ -121,7 +121,7 @@ private void readAndWriteFrames() throws IOException {
     FrameReader reader = variant.newReader(Okio.buffer(Okio.source(in)), client);
 
     Iterator<OutFrame> outFramesIterator = outFrames.iterator();
-    byte[] outBytes = bytesOut.readByteString(bytesOut.size()).toByteArray();
+    byte[] outBytes = bytesOut.readByteArray();
     OutFrame nextOutFrame = null;
 
     for (int i = 0; i < frameCount; i++) {
diff --git a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/SpdyConnectionTest.java b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/SpdyConnectionTest.java
index 453d71436ddb..07eb1cb6e8f0 100644
--- a/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/SpdyConnectionTest.java
+++ b/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/SpdyConnectionTest.java
@@ -1547,10 +1547,7 @@ private SpdyConnection.Builder connectionBuilder(MockSpdyPeer peer, Variant vari
   }
 
   private void assertStreamData(String expected, Source source) throws IOException {
-    Buffer buffer = new Buffer();
-    while (source.read(buffer, Long.MAX_VALUE) != -1) {
-    }
-    String actual = buffer.readUtf8(buffer.size());
+    String actual = Okio.buffer(source).readUtf8();
     assertEquals(expected, actual);
   }
 
diff --git a/okhttp/src/main/java/com/squareup/okhttp/Response.java b/okhttp/src/main/java/com/squareup/okhttp/Response.java
index 4008b985e2e4..3e7f8c8dbdfc 100644
--- a/okhttp/src/main/java/com/squareup/okhttp/Response.java
+++ b/okhttp/src/main/java/com/squareup/okhttp/Response.java
@@ -25,7 +25,6 @@
 import java.nio.charset.Charset;
 import java.util.Collections;
 import java.util.List;
-import okio.Buffer;
 import okio.BufferedSource;
 
 import static com.squareup.okhttp.internal.Util.UTF_8;
@@ -199,26 +198,17 @@ public final byte[] bytes() throws IOException {
         throw new IOException("Cannot buffer entire body for content length: " + contentLength);
       }
 
-      // TODO once https://github.com/square/okio/pull/41 is released.
-      // byte[] bytes = source.readByteArray();
-      // if (contentLength != -1 && contentLength != bytes.length) {
-      //   throw new IOException("Content-Length and stream length disagree");
-      // }
-      // return bytes;
-
       BufferedSource source = source();
-      Buffer buffer = new Buffer();
-      long contentRead;
+      byte[] bytes;
       try {
-        contentRead = buffer.writeAll(source);
+        bytes = source.readByteArray();
       } finally {
         Util.closeQuietly(source);
       }
-      if (contentLength != -1 && contentLength != contentRead) {
+      if (contentLength != -1 && contentLength != bytes.length) {
         throw new IOException("Content-Length and stream length disagree");
       }
-
-      return buffer.readByteArray(buffer.size());
+      return bytes;
     }
 
     /**
diff --git a/okhttp/src/main/java/com/squareup/okhttp/internal/Platform.java b/okhttp/src/main/java/com/squareup/okhttp/internal/Platform.java
index f418083b9ae5..93c73bd63523 100644
--- a/okhttp/src/main/java/com/squareup/okhttp/internal/Platform.java
+++ b/okhttp/src/main/java/com/squareup/okhttp/internal/Platform.java
@@ -367,6 +367,7 @@ static byte[] concatLengthPrefixed(List<Protocol> protocols) {
       result.writeByte(protocol.toString().length());
       result.writeUtf8(protocol.toString());
     }
+    // TODO change to result.readByteArray() when Okio 0.8.1+ is available.
     return result.readByteArray(result.size());
   }
 }
diff --git a/okhttp/src/main/java/com/squareup/okhttp/internal/http/RetryableSink.java b/okhttp/src/main/java/com/squareup/okhttp/internal/http/RetryableSink.java
index 2790c4b36e37..7c593848686f 100644
--- a/okhttp/src/main/java/com/squareup/okhttp/internal/http/RetryableSink.java
+++ b/okhttp/src/main/java/com/squareup/okhttp/internal/http/RetryableSink.java
@@ -74,6 +74,6 @@ public long contentLength() throws IOException {
 
   public void writeToSocket(BufferedSink socketOut) throws IOException {
     // Clone the content; otherwise we won't have data to retry.
-    socketOut.write(content.clone(), content.size());
+    socketOut.writeAll(content.clone());
   }
 }
diff --git a/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Http20Draft10.java b/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Http20Draft10.java
index 4f6c5eaf1104..036f0986a6b8 100644
--- a/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Http20Draft10.java
+++ b/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Http20Draft10.java
@@ -397,7 +397,7 @@ static final class Writer implements FrameWriter {
       byte flags = FLAG_END_HEADERS;
       frameHeader(streamId, length, type, flags); // TODO: CONTINUATION
       sink.writeInt(promisedStreamId & 0x7fffffff);
-      sink.write(hpackBuffer, hpackBuffer.size());
+      sink.writeAll(hpackBuffer);
     }
 
     private void headers(boolean outFinished, int streamId, int priority,
@@ -414,7 +414,7 @@ private void headers(boolean outFinished, int streamId, int priority,
       if (priority != -1) length += 4;
       frameHeader(streamId, length, type, flags); // TODO: CONTINUATION
       if (priority != -1) sink.writeInt(priority & 0x7fffffff);
-      sink.write(hpackBuffer, hpackBuffer.size());
+      sink.writeAll(hpackBuffer);
     }
 
     @Override public synchronized void rstStream(int streamId, ErrorCode errorCode)
diff --git a/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Spdy3.java b/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Spdy3.java
index a136b02958d4..535d71f2275c 100644
--- a/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Spdy3.java
+++ b/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/Spdy3.java
@@ -341,7 +341,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> request
       sink.writeInt(streamId & 0x7fffffff);
       sink.writeInt(associatedStreamId & 0x7fffffff);
       sink.writeShort((priority & 0x7) << 13 | (unused & 0x1f) << 8 | (slot & 0xff));
-      sink.write(headerBlockBuffer, headerBlockBuffer.size());
+      sink.writeAll(headerBlockBuffer);
       sink.flush();
     }
 
@@ -356,7 +356,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> request
       sink.writeInt(0x80000000 | (VERSION & 0x7fff) << 16 | type & 0xffff);
       sink.writeInt((flags & 0xff) << 24 | length & 0xffffff);
       sink.writeInt(streamId & 0x7fffffff);
-      sink.write(headerBlockBuffer, headerBlockBuffer.size());
+      sink.writeAll(headerBlockBuffer);
       sink.flush();
     }
 
@@ -371,7 +371,7 @@ public void pushPromise(int streamId, int promisedStreamId, List<Header> request
       sink.writeInt(0x80000000 | (VERSION & 0x7fff) << 16 | type & 0xffff);
       sink.writeInt((flags & 0xff) << 24 | length & 0xffffff);
       sink.writeInt(streamId & 0x7fffffff);
-      sink.write(headerBlockBuffer, headerBlockBuffer.size());
+      sink.writeAll(headerBlockBuffer);
     }
 
     @Override public synchronized void rstStream(int streamId, ErrorCode errorCode)
diff --git a/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/SpdyStream.java b/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/SpdyStream.java
index 5c459174c257..ea06d468ff6b 100644
--- a/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/SpdyStream.java
+++ b/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/SpdyStream.java
@@ -454,7 +454,7 @@ void receive(BufferedSource in, long byteCount) throws IOException {
         // Move the received data to the read buffer to the reader can read it.
         synchronized (SpdyStream.this) {
           boolean wasEmpty = readBuffer.size() == 0;
-          readBuffer.write(receiveBuffer, receiveBuffer.size());
+          readBuffer.writeAll(receiveBuffer);
           if (wasEmpty) {
             SpdyStream.this.notifyAll();
           }
diff --git a/pom.xml b/pom.xml
index a7e98ed4d5b2..32c29ed0a124 100644
--- a/pom.xml
+++ b/pom.xml
@@ -33,7 +33,7 @@
 
     <!-- Compilation -->
     <java.version>1.6</java.version>
-    <okio.version>0.7.0</okio.version>
+    <okio.version>0.8.0</okio.version>
     <!-- Targetted to jdk7u60-b13; Oracle jdk7u55-b13. -->
     <npn.version>1.1.7.v20140316</npn.version>
     <bouncycastle.version>1.48</bouncycastle.version>