fix(reactive-rpc): 🐛 always use binary encoding for Websocket messages

Author: streamich

src/__tests__/reactive-rpc/uws/ws/rx-rpc/RpcPersistentClient.spec.ts

@@ -30,7 +30,7 @@ if (process.env.TEST_E2E) {
 
     ['rpc.rx.binary.cbor', binary, cbor, cbor],
     ['rpc.rx.binary.msgpack', binary, msgpack, msgpack],
-    // ['rpc.rx.binary.json', binary, json, json],
+    ['rpc.rx.binary.json', binary, json, json],
     // ['rpc.rx.binary.json-cbor', binary, json, cbor],
     // ['rpc.rx.binary.json-msgpack', binary, json, msgpack],
     // ['rpc.rx.binary.cbor-json', binary, cbor, json],

src/reactive-rpc/server/uws/RpcApp.ts

@@ -158,7 +158,6 @@ export class RpcApp<Ctx extends ConnectionContext> {
         const resCodec = ctx.resCodec;
         const msgCodec = ctx.msgCodec;
         const encoder = resCodec.encoder;
-        const isBinary = resCodec.format !== EncodingFormat.Json || msgCodec.format === RpcMessageFormat.Binary;
         ws.rpc = new RpcMessageStreamProcessor({
           caller: this.options.caller,
           send: (messages: ReactiveRpcMessage[]) => {
@@ -167,7 +166,7 @@ export class RpcApp<Ctx extends ConnectionContext> {
             writer.reset();
             msgCodec.encodeBatch(resCodec, messages);
             const encoded = writer.flush();
-            ws.send(encoded, isBinary, false);
+            ws.send(encoded, true, false);
           },
           bufferSize: 1,
           bufferTime: 0,