simple-message-channels

Sans I/O wire protocol for Hypercore

Work In Progress

Install

$ pip install simple-message-channels

Example

from simple_message_channels import SimpleMessageChannel

smc_a = SimpleMessageChannel()
smc_b = SimpleMessageChannel()

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

for idx in range(0, len(payload)):
    smc_a.recv(payload[idx, idx + 1])

for msg in smc_a.messages:
    print(f"received: {msg}")

Output:

sent: ...
received: (0, 1, b"foo")