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's a prototype of RSocket Client API.

extern crate bytes;
extern crate futures;
extern crate rsocket_rust;
extern crate tokio;

use bytes::Bytes;
use futures::{Future, Stream};
use rsocket_rust::prelude::*;

#[test]
fn test_socket_request() {
  // Prepare a Echo server. (see: https://github.com/rsocket/rsocket-go/tree/master/cmd/echo)

  let addr = "127.0.0.1:7878".parse().unwrap();
  // create a socket.
  let socket = DuplexSocket::builder()
    .set_acceptor(Box::new(MockResponder))
    .connect(&addr);

  // setup manual
  let setup = SetupPayload::builder()
    .set_data(Bytes::from("Ready!"))
    .build();
  socket.setup(setup).wait().unwrap();

  // metadata push
  socket
    .metadata_push(
      Payload::builder()
        .set_metadata(Bytes::from("metadata only!"))
        .build(),
    )
    .wait()
    .unwrap();

  // request fnf
  let fnf = Payload::from("Mock FNF");
  socket.request_fnf(fnf).wait().unwrap();

  // request response
  for n in 0..3 {
    let sending = Payload::builder()
      .set_data(Bytes::from(format!("[{}] Hello Rust!", n)))
      .set_metadata(Bytes::from("text/plain"))
      .build();
    let result = socket.request_response(sending).wait().unwrap();
    println!("********** YES: {:?}", result);
  }

  // request stream
  let sending = Payload::builder()
    .set_data(Bytes::from("Hello Rust!"))
    .set_metadata(Bytes::from("text/plain"))
    .build();
  let task = socket
    .request_stream(sending)
    .map_err(|_| ())
    .for_each(|it| {
      println!("******* STREAM: {:?}", it);
      Ok(())
    });
  task.wait().unwrap();
}

TODO

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