diff --git a/server/network.ts b/server/network.ts index b23fe7d..0f2bcd6 100644 --- a/server/network.ts +++ b/server/network.ts @@ -34,8 +34,10 @@ export class ClientInterface { const [input_sender, input_receiver] = channel(); const [output_sender, output_receiver] = channel(); input_sender.send_all(parsed_stream(mts.message_to_server_parser())(connection.readable)) + .catch((err) => log("Deserialisation failure :", err.message)) .finally(() => input_sender.send({ kind: "exit" })); serialized_stream(output_receiver.iter())(connection.writable) + .catch((err) => log("Serialisation failure :", err.message)) .finally(() => input_sender.send({ kind: "exit" })); return new ClientInterface(input_receiver, output_sender); }