diff --git a/src/ripple/overlay/impl/PeerImp.cpp b/src/ripple/overlay/impl/PeerImp.cpp
index eb1602a6e..01b73e92f 100644
--- a/src/ripple/overlay/impl/PeerImp.cpp
+++ b/src/ripple/overlay/impl/PeerImp.cpp
@@ -706,7 +706,7 @@ PeerImp::on_read_protocol (error_code ec, std::size_t bytes_transferred)
     if (! ec)
     {
         read_buffer_.commit (bytes_transferred);
-        ec = message_stream_.write_one (read_buffer_.data());
+        ec = message_stream_.write (read_buffer_.data());
         read_buffer_.consume (read_buffer_.size());
     }
 
diff --git a/src/ripple/overlay/impl/PeerImp.h b/src/ripple/overlay/impl/PeerImp.h
index 828ee5e51..1846a27b5 100644
--- a/src/ripple/overlay/impl/PeerImp.h
+++ b/src/ripple/overlay/impl/PeerImp.h
@@ -39,6 +39,7 @@
 
 #include <beast/asio/IPAddressConversion.h>
 #include <beast/asio/placeholders.h>
+#include <beast/asio/streambuf.h>
 #include <beast/http/message.h>
 #include <beast/http/parser.h>
 
@@ -169,12 +170,12 @@ private:
     // The slot assigned to us by PeerFinder
     PeerFinder::Slot::ptr slot_;
 
-    boost::asio::streambuf read_buffer_;
+    beast::asio::streambuf read_buffer_;
     boost::optional <beast::http::message> http_message_;
     boost::optional <beast::http::parser> http_parser_;
     message_stream message_stream_;
 
-    boost::asio::streambuf write_buffer_;
+    beast::asio::streambuf write_buffer_;
 
     std::unique_ptr <LoadEvent> load_event_;