diff --git a/network/stream.py b/network/stream.py
index 97658910..eeb85895 100644
--- a/network/stream.py
+++ b/network/stream.py
@@ -9,6 +9,8 @@ class Stream(IStream):
 
         peer_store = context.peer_store
         peer_addr = peer_store.get(peer_id)
+        ip = peer_addr.get_protocol("ip4")
+        port = peer_addr.get_protocol("tcp")
 
         # look up peer_id -> multiaddr in peer store
         # parse multiaddr and set_protocol based on it
@@ -37,18 +39,23 @@ class Stream(IStream):
         read from stream
         :return: bytes of input
         """
-        pass
+        return self.reader.read(-1)
 
     def write(self, _bytes):
         """
         write to stream
         :return: number of bytes written
         """
-        pass
+        return self.write_to_stream(_bytes)
+
+    async def write_to_stream(self, _bytes):
+        to_return = self.writer.write(_bytes)
+        await self.writer.drain()
+        return to_return
 
     def close(self):
         """
         close stream
         :return: true if successful
         """
-        pass
+        self.writer.close()
diff --git a/requirements.txt b/requirements.txt
index 404572b1..fa498a07 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1 +1,2 @@
-asyncio
\ No newline at end of file
+asyncio
+multiaddr
\ No newline at end of file