Mirror/Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2026-07-25 09:18:09 -07:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
Mark Qvist
2026-07-24 15:33:19 +02:00
parent 6a761a768c
commit 12c21d4e25
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/channel.py
+3 -3
View File
@@ -1,7 +1,7 @@
from __future__ import annotations
import threading
import RNS
from RNS.Channel import MessageState, ChannelOutletBase, Channel, MessageBase
from RNS.Channel import MessageState, LinkChannelOutlet, Channel, MessageBase
import RNS.Buffer
from RNS.vendor import umsgpack
from typing import Callable
@@ -71,7 +71,7 @@ class Packet:
self.delivered_callback(self)
class ChannelOutletTest(ChannelOutletBase):
class ChannelOutletTest(LinkChannelOutlet):
def get_packet_state(self, packet: Packet) -> MessageState:
return packet.state
@@ -93,7 +93,7 @@ class ChannelOutletTest(ChannelOutletBase):
self._usable = True
self.packets = []
self.lock = threading.RLock()
self.packet_callback: Callable[[ChannelOutletBase, bytes], None] | None = None
self.packet_callback: Callable[[LinkChannelOutlet, bytes], None] | None = None
def send(self, raw: bytes) -> Packet:
with self.lock: