diff --git a/pybtc/connector/block_loader.py b/pybtc/connector/block_loader.py
index 7194a14..fdf0511 100644
--- a/pybtc/connector/block_loader.py
+++ b/pybtc/connector/block_loader.py
@@ -156,13 +156,12 @@ class Worker:
 
 
 
-    async def message_loop(self, worker):
+    async def message_loop(self):
+        self.reader = await self.get_pipe_reader(self.in_reader)
         while True:
-            msg_type, msg = await self.pipe_get_msg(worker.reader)
+            msg_type, msg = await self.pipe_get_msg(self.reader)
             if msg_type ==  b'pipe_read_error':
-                if not worker.is_alive():
-                    return
-                continue
+                return
 
             if msg_type == b'result':
                 msg
diff --git a/pybtc/connector/utils.py b/pybtc/connector/utils.py
index a857ab3..6308a46 100644
--- a/pybtc/connector/utils.py
+++ b/pybtc/connector/utils.py
@@ -26,6 +26,7 @@ def decode_block_tx(block):
     s = get_stream(block)
     b = dict()
     b["amount"] = 0
+    b["size"] = len(block)
     b["strippedSize"] = 80
     b["version"] = unpack("<L", s.read(4))[0]
     b["versionHex"] = pack(">L", b["version"]).hex()