Skip to content

Commit e609644

Browse files
committed
Moved max_size to mixin for reuse
1 parent c24c3d0 commit e609644

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

async_substrate_interface/async_substrate.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -685,7 +685,7 @@ def __init__(
685685
self.ws = Websocket(
686686
url,
687687
options={
688-
"max_size": 2**32,
688+
"max_size": self.ws_max_size,
689689
"write_limit": 2**16,
690690
},
691691
)

async_substrate_interface/sync_substrate.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -566,12 +566,12 @@ def name(self):
566566

567567
def connect(self, init=False):
568568
if init is True:
569-
return connect(self.chain_endpoint, max_size=2**32)
569+
return connect(self.chain_endpoint, max_size=self.ws_max_size)
570570
else:
571571
if not self.ws.close_code:
572572
return self.ws
573573
else:
574-
return connect(self.chain_endpoint, max_size=2**32)
574+
return connect(self.chain_endpoint, max_size=self.ws_max_size)
575575

576576
def get_storage_item(self, module: str, storage_function: str):
577577
if not self._metadata:

async_substrate_interface/types.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -344,6 +344,7 @@ class SubstrateMixin(ABC):
344344
runtime_config: RuntimeConfigurationObject
345345
type_registry: Optional[dict]
346346
ss58_format: Optional[int]
347+
ws_max_size = 2**32
347348

348349
@property
349350
def chain(self):

0 commit comments

Comments
 (0)