dont convert message to string for json serializer

xconnio · May 4, 2024 · 45542c7 · 45542c7
1 parent 9f5c7bf
commit 45542c7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/lib/src/server.dart b/lib/src/server.dart
@@ -28,8 +28,7 @@ class Server {
     Future.microtask(() async {
       while (true) {
         var message = await baseSession.receive();
-        var decodedMessage = Uint8List.fromList((message as String).codeUnits);
-        var msg = baseSession.serializer.deserialize(decodedMessage);
+        var msg = baseSession.serializer.deserialize(message);
         await router.receiveMessage(baseSession, msg);
       }
     });

diff --git a/lib/src/wsacceptor.dart b/lib/src/wsacceptor.dart
@@ -29,14 +29,7 @@ class WAMPSessionAcceptor {
     final sessionStreamController = StreamController.broadcast();
 
     wsStreamSubscription = ws.listen((message) {
-      dynamic data;
-      if (getSubProtocol(_serializer) == jsonSubProtocol) {
-        data = Uint8List.fromList((message as String).codeUnits);
-      } else {
-        data = message;
-      }
-
-      MapEntry<Uint8List, bool> received = a.receive(data);
+      MapEntry<Object, bool> received = a.receive(message);
       ws.add(received.key);
       if (received.value) {
         wsStreamSubscription.onData(sessionStreamController.add);