optimize codes.

Author: jjeffcaii

Cargo.toml

@@ -7,12 +7,18 @@ license = "Apache-2.0"
 readme = "README.md"
 repository = "https://github.com/jjeffcaii/rsocket-rust"
 homepage = "https://github.com/jjeffcaii/rsocket-rust"
-description = """
-rsocket-rust is an implementation of the RSocket protocol in Rust.
-"""
+description = "rsocket-rust is an implementation of the RSocket protocol in Rust."
 
 [dependencies]
+log = "0.4.8"
 bytes = "0.4.12"
+futures = "0.1.28"
 tokio = "0.1.22"
+
+[dev-dependencies]
+env_logger = "0.6.2"
 hex = "0.3.2"
-futures = "0.1.28"
+
+[[example]]
+name = "echo"
+path = "examples/echo/main.rs"

README.md

@@ -1,19 +1,21 @@
 # rsocket-rust
+
 ![logo](./logo.jpg)
 
 [![Crates.io](https://img.shields.io/crates/v/rsocket_rust)](https://crates.io/crates/rsocket_rust)
 [![Crates.io](https://img.shields.io/crates/d/rsocket_rust)](https://crates.io/crates/rsocket_rust)
 [![License](https://img.shields.io/github/license/jjeffcaii/rsocket-rust.svg)](https://github.com/jjeffcaii/rsocket-rust/blob/master/LICENSE)
 [![GitHub Release](https://img.shields.io/github/release-pre/jjeffcaii/rsocket-rust.svg)](https://github.com/jjeffcaii/rsocket-rust/releases)
 
-> rsocket-rust is an implementation of the RSocket protocol in Rust.
-<br>It is under active development. Do not use it in a production environment.
+> rsocket-rust is an implementation of the RSocket protocol in Rust.  
+It is under active development. **Do not use it in a production environment!**
 
 ## Example
 
 > Here are some example codes which show how RSocket works in Rust. :sunglasses:
 
 ### Server
+
 ```rust
 extern crate bytes;
 extern crate futures;
@@ -78,36 +80,38 @@ fn test_client() {
 ```
 
 ## Dependencies
-1. [Tokio](https://tokio.rs/)
-2. [futures-rs](http://rust-lang-nursery.github.io/futures-rs/)
+
+- [Tokio](https://tokio.rs/)
+- [futures-rs](http://rust-lang-nursery.github.io/futures-rs/)
 
 ## TODO
- - Codec
-   - [x] Setup
-   - [x] Keepalive
-   - [x] Payload
-   - [x] RequestResponse
-   - [x] RequestStream
-   - [x] RequestChannel
-   - [x] RequestFireAndForget
-   - [x] MetadataPush
-   - [x] RequestN
-   - [x] Resume
-   - [x] ResumeOK
-   - [x] Cancel
-   - [x] Error
-   - [x] Lease
- - Operations
-   - [x] METADATA_PUSH
-   - [x] REQUEST_FNF
-   - [x] REQUEST_RESPONSE
-   - [x] REQUEST_STREAM
-   - [ ] REQUEST_CHANNEL
- - Transport
-   - [x] TCP
-   - [ ] Websocket
- - Rx
-   - [ ] ...
- - High Level APIs
-   - [x] Client
-   - [x] Server
+
+- Codec
+  - [x] Setup
+  - [x] Keepalive
+  - [x] Payload
+  - [x] RequestResponse
+  - [x] RequestStream
+  - [x] RequestChannel
+  - [x] RequestFireAndForget
+  - [x] MetadataPush
+  - [x] RequestN
+  - [x] Resume
+  - [x] ResumeOK
+  - [x] Cancel
+  - [x] Error
+  - [x] Lease
+- Operations
+  - [x] METADATA_PUSH
+  - [x] REQUEST_FNF
+  - [x] REQUEST_RESPONSE
+  - [x] REQUEST_STREAM
+  - [ ] REQUEST_CHANNEL
+- Transport
+  - [x] TCP
+  - [ ] Websocket
+- Rx
+  - [ ] ...
+- High Level APIs
+  - [x] Client
+  - [x] Server

examples/echo/main.rs

@@ -0,0 +1,42 @@
+#![allow(unused_variables)]
+#![allow(unused_imports)]
+#![allow(dead_code)]
+
+#[macro_use]
+extern crate log;
+extern crate bytes;
+extern crate env_logger;
+extern crate futures;
+extern crate rsocket_rust;
+extern crate tokio;
+
+use bytes::Bytes;
+use futures::prelude::*;
+use rsocket_rust::prelude::*;
+
+fn main() {
+  env_logger::builder()
+    .default_format_timestamp_nanos(true)
+    .init();
+
+  let server = RSocketFactory::receive()
+    .transport(URI::Tcp("127.0.0.1:7878"))
+    .acceptor(|setup, sending_socket| {
+      info!("accept setup: {:?}", setup);
+      // TODO: use tokio runtime?
+      // std::thread::spawn(move || {
+      //   let resp = sending_socket
+      //     .request_response(
+      //       Payload::builder()
+      //         .set_data(Bytes::from("Hello Client!"))
+      //         .build(),
+      //     )
+      //     .wait()
+      //     .unwrap();
+      //   println!(">>>>> response success: {:?}", resp);
+      // });
+      Box::new(MockResponder)
+    })
+    .serve();
+  tokio::run(server);
+}