mirror of
https://github.com/OMGeeky/flucto-heisskleber.git
synced 2026-02-13 21:18:09 +01:00
This commit is contained in:
@@ -24,10 +24,10 @@ class SerialSender(Sender[T]):
|
||||
packer: Function to pack data for sending.
|
||||
"""
|
||||
|
||||
def __init__(self, config: SerialConf, pack: Packer[T]) -> None:
|
||||
def __init__(self, config: SerialConf, packer: Packer[T]) -> None:
|
||||
"""SerialSink constructor."""
|
||||
self.config = config
|
||||
self.packer = pack
|
||||
self.packer = packer
|
||||
self._loop = asyncio.get_running_loop()
|
||||
self._executor = ThreadPoolExecutor(max_workers=2)
|
||||
self._lock = asyncio.Lock()
|
||||
|
||||
Reference in New Issue
Block a user