# Error messages:
sends.append(MessageTemplate(
{'event': {'const': 'error'}}))
- self.bus.register(self.name, 'ModbusMaster',
- sends, receives, self._receive)
+ self.bus.register(self.name, 'ModbusMaster', sends,
+ [(receives, self._receive)])
async def _receive(self, message: Message) -> None:
await self._queue.put(message)
sends = [MessageTemplate({'event': {'const': 'received'}}),
MessageTemplate({'event': {'const': 'crc error'}}),
MessageTemplate({'event': {'const': 'sent'}})]
- self.bus.register(self.name, 'ModbusSlave', sends, [], self._receive)
-
- async def _receive(self, message: Message) -> None:
- pass
+ self.bus.register(self.name, 'ModbusSlave', sends, [])
async def _process_request(self, modbus_request: bytes) -> bytes:
if len(modbus_request) < 4: