/nats_codec: NATS Command definitions +DecoderandEncoderto work with asynchronous I/O in a type safe manner/nats_sans_io: 100% synchronous state-machine driven implementation of the NATS protocol for clients. For more information on sans-IO, see this blog post./nats_client: An asynchronous NATS client in Tokio that uses/nats_sans_ioto facilitate communication, supporting both subscribing and publishing, with matching examples
- Publisher: Publishes the UTC+05:30 timestamp to the specified NATS server
$ RUST_LOG=info c r --example publisher -- --help
Usage: publisher <HOST> <PORT> <SUBJECT> [LIMIT]
Arguments:
<HOST>
<PORT>
<SUBJECT>
[LIMIT]
Options:
-h, --help Print help- Send 5 messages to
time.us.east@demo.nats.io:4222
$ RUST_LOG=info cargo r --example publisher -- demo.nats.io 4222 time.us.east 5- Subscriber: Publishes the UTC+05:30 timestamp to the specified NATS server
$ RUST_LOG=info c r --example subscriber -- --help
Usage: subscriber <HOST> <PORT> <SUBJECT> [MAX_MSGS] [QUEUE_GROUP]
Arguments:
<HOST>
<PORT>
<SUBJECT>
[MAX_MSGS]
[QUEUE_GROUP]
Options:
-h, --help Print help- Receive 3 messages with the
time.us.>subject fromdemo.nats.io:4222
RUST_LOG=info cargo r --example publisher -- demo.nats.io 4222 time.us.> 3