rsocket_server.dart

import 'package:rsocket/shelf.dart';

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