prepare for release v0.5.2

Author: jjeffcaii

rsocket-messaging/Cargo.toml

@@ -3,6 +3,11 @@ name = "rsocket_rust_messaging"
 version = "0.5.2"
 authors = ["Jeffsky <[email protected]>"]
 edition = "2018"
+license = "Apache-2.0"
+readme = "README.md"
+repository = "https://github.com/rsocket/rsocket-rust"
+homepage = "https://github.com/rsocket/rsocket-rust"
+description = "Communicate with Spring RSocket Messaging."
 
 [dependencies]
 futures = "0.3.5"
@@ -14,11 +19,11 @@ hex = "0.4.2"
 url = "2.1.1"
 
 [dependencies.rsocket_rust]
-path = "../rsocket"
+version = "0.5.2"
 features = ["frame"]
 
 [dependencies.rsocket_rust_transport_tcp]
-path = "../rsocket-transport-tcp"
+version = "0.5.2"
 
 [dependencies.rsocket_rust_transport_websocket]
-path = "../rsocket-transport-websocket"
+version = "0.5.2"

rsocket-messaging/README.md

@@ -0,0 +1,7 @@
+# RSocket Messaging
+
+Communicate with Spring RSocket Messaging.
+
+## Example
+
+Here's a good example: [https://github.com/feuyeux/kio](https://github.com/feuyeux/kio).

rsocket-transport-tcp/Cargo.toml

@@ -15,7 +15,7 @@ futures = "0.3.5"
 bytes = "0.5.4"
 
 [dependencies.rsocket_rust]
-path = "../rsocket"
+version = "0.5.2"
 features = ["frame"]
 
 [dependencies.tokio]

rsocket-transport-tcp/README.md

@@ -1 +1,83 @@
 # RSocket Transport For TCP
+
+## Example
+
+Add dependencies in your `Cargo.toml`.
+
+```toml
+[dependencies]
+tokio = "0.2.21"
+rsocket_rust = "0.5.2"
+rsocket_rust_transport_tcp = "0.5.2"
+```
+
+### Server
+
+```rust
+use log::info;
+use rsocket_rust::prelude::{EchoRSocket, RSocketFactory, ServerResponder};
+use rsocket_rust_transport_tcp::TcpServerTransport;
+use std::error::Error;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
+    let transport: TcpServerTransport = TcpServerTransport::from("127.0.0.1:7878");
+
+    let responder: ServerResponder = Box::new(|setup, _socket| {
+        info!("accept setup: {:?}", setup);
+        Ok(Box::new(EchoRSocket))
+        // Or you can reject setup
+        // Err(From::from("SETUP_NOT_ALLOW"))
+    });
+
+    let on_start: Box<dyn FnMut() + Send + Sync> =
+        Box::new(|| info!("+++++++ echo server started! +++++++"));
+
+    RSocketFactory::receive()
+        .transport(transport)
+        .acceptor(responder)
+        .on_start(on_start)
+        .serve()
+        .await?;
+
+    Ok(())
+}
+
+```
+
+### Client
+
+```rust
+use log::info;
+use rsocket_rust::prelude::{ClientResponder, EchoRSocket, Payload, RSocket, RSocketFactory};
+use rsocket_rust_transport_tcp::TcpClientTransport;
+use std::error::Error;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
+    let responder: ClientResponder = Box::new(|| Box::new(EchoRSocket));
+
+    let client = RSocketFactory::connect()
+        .acceptor(responder)
+        .transport(TcpClientTransport::from("127.0.0.1:7878"))
+        .setup(Payload::from("READY!"))
+        .mime_type("text/plain", "text/plain")
+        .start()
+        .await
+        .unwrap();
+
+    let request_payload: Payload = Payload::builder()
+        .set_data_utf8("Hello World!")
+        .set_metadata_utf8("Rust")
+        .build();
+
+    let res = client.request_response(request_payload).await.unwrap();
+
+    info!("got: {:?}", res);
+
+    client.close();
+
+    Ok(())
+}
+
+```

rsocket-transport-wasm/Cargo.toml

@@ -19,15 +19,15 @@ serde = "1.0.110"
 serde_derive = "1.0.110"
 
 [dependencies.rsocket_rust]
-path = "../rsocket"
+version = "0.5.2"
 features = ["frame"]
 
 [dependencies.wasm-bindgen]
 version = "0.2.62"
 features = ["serde-serialize"]
 
 [dependencies.web-sys]
-version = "0.3.37"
+version = "0.3.39"
 features = [
   "FileReader",
   "ProgressEvent",

rsocket-transport-wasm/README.md

@@ -7,7 +7,7 @@ See: [https://github.com/jjeffcaii/rsocket-rust-wasm-example](https://github.com
 ## TODO
 
 - [ ] MetadataPush
-- [ ] FireAndForget
+- [x] FireAndForget
 - [x] RequestResponse
 - [ ] RequestStream
 - [ ] RequestChannel

rsocket-transport-websocket/Cargo.toml

@@ -17,7 +17,7 @@ url = "2.1.1"
 tokio-tungstenite = "0.10.1"
 
 [dependencies.rsocket_rust]
-path = "../rsocket"
+version = "0.5.2"
 features = ["frame"]
 
 [dependencies.tokio]

rsocket-transport-websocket/README.md

@@ -6,9 +6,9 @@ Add dependencies in your `Cargo.toml`.
 
 ```toml
 [dependencies]
-tokio = "0.2.16"
-rsocket_rust = "0.5.1"
-rsocket_rust_transport_websocket = "0.5.1"
+tokio = "0.2.21"
+rsocket_rust = "0.5.2"
+rsocket_rust_transport_websocket = "0.5.2"
 ```
 
 ### Server