move self.server_side to Message class
This commit is contained in:
@@ -11,11 +11,10 @@ class AsyncStream(Message):
|
|||||||
|
|
||||||
def __init__(self, reader, writer, addr, remote_stream, server_side: bool
|
def __init__(self, reader, writer, addr, remote_stream, server_side: bool
|
||||||
) -> None:
|
) -> None:
|
||||||
super().__init__()
|
super().__init__(server_side)
|
||||||
self.reader = reader
|
self.reader = reader
|
||||||
self.writer = writer
|
self.writer = writer
|
||||||
self.remoteStream = remote_stream
|
self.remoteStream = remote_stream
|
||||||
self.server_side = server_side
|
|
||||||
self.addr = addr
|
self.addr = addr
|
||||||
|
|
||||||
'''
|
'''
|
||||||
|
|||||||
@@ -74,8 +74,9 @@ class Message(metaclass=IterRegistry):
|
|||||||
_registry = []
|
_registry = []
|
||||||
new_stat_data = {}
|
new_stat_data = {}
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self, server_side: bool):
|
||||||
self._registry.append(weakref.ref(self))
|
self._registry.append(weakref.ref(self))
|
||||||
|
self.server_side = server_side
|
||||||
self.header_valid = False
|
self.header_valid = False
|
||||||
self.header_len = 0
|
self.header_len = 0
|
||||||
self.data_len = 0
|
self.data_len = 0
|
||||||
|
|||||||
Reference in New Issue
Block a user