Crate connect

This crate provides a reliable, fault-tolerant, and brokerless message-queue abstraction over asynchronous network streams.

Why?

When building networked applications, developers shouldn't have to focus on repeatedly solving the problem of reliable, fault-tolerant message delivery over byte-streams. By using a message queue abstraction, crate users can focus on core application logic and leave the low-level networking and message-queue guarantees to the abstraction.

Protobuf

This crate relies on the use of Protocol Buffers due to it being widely adopted and industry-proven. All messages are Protobuf messages that are packed into a Protobuf Any type and then sent over the wire. Message recipients must decide what Protobuf message type it is, and correspondingly unpack the Any into a particular message type.

Examples

Please use the examples provided to help understand crate usage.

Modules

tcp	TCP transport client and listener implementations.
tls	TLS transport client and listener implementations.

Structs

Connection	Wrapper around a ConnectionReader and ConnectionWriter to read and write on a network connection
ConnectionReader	An interface to read messages from the network connection
ConnectionWriter	An interface to write messages to the network connection

Traits

SinkExt	An extension trait for Sinks that provides a variety of convenient combinator functions.
StreamExt	An extension trait for Streams that provides a variety of convenient combinator functions.