add server setup acceptor impl.

Author: jjeffcaii

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rsocket_rust"
-version = "0.1.1"
+version = "0.1.2"
 authors = ["Jeffsky <[email protected]>"]
 edition = "2018"
 license = "Apache-2.0"

README.md

@@ -15,21 +15,39 @@
 
 ### Server
 ```rust
+extern crate bytes;
 extern crate futures;
 extern crate rsocket_rust;
 
+use bytes::Bytes;
 use futures::prelude::*;
 use rsocket_rust::prelude::*;
 
 #[test]
 fn test_serve() {
   RSocketFactory::receive()
     .transport(URI::Tcp("127.0.0.1:7878"))
-    .acceptor(Box::new(MockResponder))
+    .acceptor(|setup, sending_socket| {
+      println!("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()
     .wait()
     .unwrap();
 }
+
 ```
 
 ### Client
@@ -59,6 +77,10 @@ fn test_client() {
 }
 ```
 
+## Dependencies
+1. [Tokio](https://tokio.rs/)
+2. [futures-rs](http://rust-lang-nursery.github.io/futures-rs/)
+
 ## TODO
  - Codec
    - [x] Setup

src/core/misc.rs

@@ -1,7 +1,7 @@
 use std::sync::atomic::{AtomicU32, Ordering};
 use std::sync::Arc;
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub struct StreamID {
   inner: Arc<AtomicU32>,
 }

src/core/mod.rs

@@ -4,5 +4,5 @@ mod socket;
 mod spi;
 
 pub use callers::*;
-pub use socket::{DuplexSocket, DuplexSocketBuilder,EmptyRSocket};
+pub use socket::{DuplexSocket, DuplexSocketBuilder,EmptyRSocket,Acceptor};
 pub use spi::{RSocket,MockResponder};