channels-nats 0.3.0
“NATS-backed channel layer for Django Channels: one Go binary instead of Redis, Windows-friendly”
Code runs at import or install timePublishes an MQTT message
SHA-256f9d7f1a9fc874331d4190dfd4f2f06ffa50e5d04e793c467ea70fb7f6a9a5b16
MaleculeO(S)H(Cm)
Evidence
219:52… ions):
220 state.process_subscriptions[subject] = await client.subscribe(subject, cb=self._process_deliver(state))
221 for channel, box in state.mailboxes.items():
222 if box.subscription …
351:52… ayload on nats-server or send less"
352 )
353 await client.publish(subject, payload, headers=headers)
354
355 def _enqueue(self, box: _Mailbox, channel: str, message: Message) -> None:
356 now …
No evidence locations were recorded for this file. Raw result