rsocket

Description:

rsocket

RSocket Dart SDK #
Examples #
Client #
import 'package:rsocket/rsocket_connector.dart';
import 'package:rsocket/payload.dart';

void main() async {
var rsocket = await RSocketConnector.create().connect('tcp://127.0.0.1:42252');
var result = await rsocket.requestResponse(Payload.fromText('text/plain', 'Ping'));
print(result.getDataUtf8());
}
copied to clipboard
Server #
import 'package:rsocket/rsocket_server.dart';
import 'package:rsocket/payload.dart';
import 'package:rsocket/rsocket.dart';

void main() async {
const listenUrl = 'tcp://0.0.0.0:42252';
var closeable = await RSocketServer.create(requestResponseAcceptor((payload) {
return Future.value(Payload.fromText('text/plain', 'Pong'));
})).bind(listenUrl);
print('RSocket Server started on ${listenUrl}');
}

copied to clipboard
RSocket Service Proxy & Routing #
Please refer https://github.com/rsocket/rsocket-dart/tree/master/lib/route
RSocket #

Operations

✅ REQUEST_FNF
✅ REQUEST_RESPONSE
✅ REQUEST_STREAM
❌ REQUEST_CHANNEL
✅ METADATA_PUSH


More Operations

✅ Error
❌ Cancel
✅ Keepalive


QoS

❌ RequestN
❌ Lease


Transport

✅ TCP
✅ Websocket


High Level APIs

✅ Client
✅ Server


Misc

✅ RxDart



References #

RSocket: https://rsocket.io
Dart: https://dart.dev/