connector

pybtc/connector/block_loader.py

@@ -11,7 +11,7 @@ import aiojsonrpc
 import traceback
 from pybtc.connector.utils import decode_block_tx
 
-import marshal as pickle
+import _pickle as pickle
 from lru import LRU
 
 

pybtc/connector/connector.py

@@ -12,7 +12,7 @@ import zmq
 import zmq.asyncio
 import asyncio
 import time
-from marshal import loads, dumps
+from _pickle import loads, dumps
 
 class Connector:
     def __init__(self, node_rpc_url, node_zerromq_url, logger,

pybtc/test/block.py

@@ -604,9 +604,9 @@ class BlockDeserializeTests(unittest.TestCase):
             Block(fc[:-1], format="raw", keep_raw_tx=False),
               )
 
-        import _pickle as pickle
+        import ujson as pickle
         qt = time.time()
-        k = pickle.dumps(bt)
+        k = pickle.dumps(bt[0]["tx"][0])
         print("decoded block dump", time.time() - qt)
         qt = time.time()
         p = pickle.loads(k)