@@ -1613,8 +1613,7 @@ async def _process_response(
1613
1613
q = bytes (query_value )
1614
1614
else :
1615
1615
q = query_value
1616
- obj = await self .decode_scale (value_scale_type , q , True )
1617
- result = obj
1616
+ result = await self .decode_scale (value_scale_type , q )
1618
1617
if asyncio .iscoroutinefunction (result_handler ):
1619
1618
# For multipart responses as a result of subscriptions.
1620
1619
message , bool_result = await result_handler (response , subscription_id )
@@ -2346,7 +2345,6 @@ async def get_constant(
2346
2345
return await self .decode_scale (
2347
2346
constant .type ,
2348
2347
bytes (constant .constant_value ),
2349
- return_scale_obj = True ,
2350
2348
)
2351
2349
else :
2352
2350
return None
@@ -2571,7 +2569,6 @@ def concat_hash_len(key_hasher: str) -> int:
2571
2569
item_key_obj = await self .decode_scale (
2572
2570
type_string = f"({ ', ' .join (key_type_string )} )" ,
2573
2571
scale_bytes = bytes .fromhex (item [0 ][len (prefix ) :]),
2574
- return_scale_obj = True ,
2575
2572
)
2576
2573
2577
2574
# strip key_hashers to use as item key
@@ -2592,9 +2589,7 @@ def concat_hash_len(key_hasher: str) -> int:
2592
2589
item_bytes = hex_to_bytes (item [1 ])
2593
2590
2594
2591
item_value = await self .decode_scale (
2595
- type_string = value_type ,
2596
- scale_bytes = item_bytes ,
2597
- return_scale_obj = True ,
2592
+ type_string = value_type , scale_bytes = item_bytes
2598
2593
)
2599
2594
except Exception as _ :
2600
2595
if not ignore_decoding_errors :
0 commit comments