diff --git a/lbry/wallet/bcd_data_stream.py b/lbry/wallet/bcd_data_stream.py
index 1c04be005..9314f3d46 100644
--- a/lbry/wallet/bcd_data_stream.py
+++ b/lbry/wallet/bcd_data_stream.py
@@ -4,8 +4,8 @@ from io import BytesIO
 
 class BCDataStream:
 
-    def __init__(self, data=None):
-        self.data = BytesIO(data)
+    def __init__(self, data=None, fp=None):
+        self.data = fp or BytesIO(data)
 
     def reset(self):
         self.data.seek(0)