У меня есть программа nodejs, которая должна получать поток данных через веб-сокет, и, как только некоторые данные будут получены, отправлять их по tcp-соединению какому-либо внешнему клиенту.
const server = net.createServer(function (connection) {
connection.on('data', data => {
toWay.handleRequest(data);
});
});
toWay - это большой класс, где в зависимости от данных работают разные методы, которые делают запрос на внешний сервер и в функции обратного вызова отправляют некоторые данные внешнему клиенту.
class TwoWayComm {
constructor() {...}
startStream(request) {
this.myMarket.websockets.trades(request[1], (trades, error) => {
//here I have to send to my external client, something like
//connection.write(trades)
});
};
...
}
const toWay = new TwoWayComm();
Таких методов здесь около 10.
Очевидно, я не могу использовать connection.write (что-то) внутри net.createServer (function (connection) {...
Что вы можете предложить мне для сборки приложения?