if (!this.wstream.write(something)) {
            // handle backpressure
            return new Promise<void>((resolve, reject) => {
                this.wstream.once('drain', () => {
                    resolve();