channels 0.5.0

Bidirectional channel-like communication over generic Read/Write streams
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

[crates-io]: https://crates.io/crates/channels

[license-badge]: https://img.shields.io/crates/l/channels?style=for-the-badge
[version-badge]: https://img.shields.io/crates/v/channels?style=for-the-badge
[downloads-badge]: https://img.shields.io/crates/d/channels?style=for-the-badge

# **channels-rs**

[![license-badge]][crates-io]
[![version-badge]][crates-io]
[![downloads-badge]][crates-io]

**channels** is a crate that allows for easy and fast communication between processes, threads and systems.

Anything you might need can be found over at the documentation @ [docs.rs](https://docs.rs/channels)

# Examples

Simple echo server:

```rust
use std::io;
use std::net::TcpListener;

use channels;

	fn main() -> io::Result<()> {
		let listener = TcpListener::bind("0.0.0.0:1337")?;

		loop {
			let (stream, _) = listener.accept()?;
			let (mut tx, mut rx) = channels::channel::<i32, _>(stream);

			let client_data = rx.recv()?;

			println!("Client sent: {}", client_data);

			tx.send(client_data)?;
		}

 	Ok(())
}
```

Simple echo client:

```rust
use std::io;
use std::net::TcpStream;

fn main() -> io::Result<()> {
		let stream = TcpStream::connect("127.0.0.1:1337")?;
		let (mut tx, mut rx) = channels::channel::<i32, _>(stream);

		tx.send(1337_i32)?;

		let received_data = rx.recv()?;

		assert_eq!(received_data, 1337_i32);

	Ok(())
}
```