simple-message-channels

Hypercore的Sans I/O线协议

安装

$ pip install simple-message-channels

示例

from simple_message_channels import SimpleMessageChannel

smc1 = SimpleMessageChannel()
smc2 = SimpleMessageChannel()

payload = smc1.send(0, 1, b"foo")
print(f"sent: {payload}")

for idx in range(0, len(payload)):
    smc2.recv(payload[idx : idx + 1])
print(f"received: {smc2.messages}")

输出

sent: b'\x04\x01foo'
received: [(0, 1, b'foo')]