Sans I/O wire protocol for Hypercore
|
||
---|---|---|
simple_message_channels | ||
test | ||
.drone.yml | ||
.gitignore | ||
CHANGELOG.md | ||
LICENSE | ||
poetry.lock | ||
pyproject.toml | ||
README.md |
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")
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:
(0, 1, b"foo")