rsocket-rust

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

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(|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

extern crate futures;
extern crate rsocket_rust;

use futures::prelude::*;
use rsocket_rust::prelude::*;

#[test]
fn test_client() {
  let cli = RSocketFactory::connect()
    .acceptor(||Box::new(MockResponder))
    .transport(URI::Tcp("127.0.0.1:7878"))
    .setup(Payload::from("READY!"))
    .mime_type("text/plain", "text/plain")
    .start()
    .unwrap();
  let pa = Payload::builder()
    .set_data_utf8("Hello World!")
    .set_metadata_utf8("Rust!")
    .build();
  let resp = cli.request_response(pa).wait().unwrap();
  println!("******* response: {:?}", resp);
}

Dependencies

1. Tokio
2. futures-rs

TODO

• Codec
  • Setup
  • Keepalive
  • Payload
  • RequestResponse
  • RequestStream
  • RequestChannel
  • RequestFireAndForget
  • MetadataPush
  • RequestN
  • Resume
  • ResumeOK
  • Cancel
  • Error
  • Lease
• Operations
  • METADATA_PUSH
  • REQUEST_FNF
  • REQUEST_RESPONSE
  • REQUEST_STREAM
  • REQUEST_CHANNEL
• Transport
  • TCP
  • Websocket
• Rx
  • ...
• High Level APIs
  • Client
  • Server