diff --git a/packages/transport-node/src/transport.ts b/packages/transport-node/src/transport.ts index 2121c19e..6d4f2722 100644 --- a/packages/transport-node/src/transport.ts +++ b/packages/transport-node/src/transport.ts @@ -45,9 +45,9 @@ export class TransportNode implements Types.Transport { ) as ReadableStream; this._fromDevice = fromDeviceSource.pipeThrough(Utils.fromDeviceStream()); - // Stream for data going FROM the application TO the Meshtastic device. - const toDeviceTransform = new TransformStream(); - this._toDevice = toDeviceTransform.writable; + // Stream for data going FROM the application TO the Meshtastic device. + const toDeviceTransform = Utils.toDeviceStream; + this._toDevice = toDeviceTransform.writable; // The readable end of the transform is then piped to the Node.js socket. // A similar assertion is needed here because `Writable.toWeb` also returns