Guy Margalit guymguym
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /* jshint browser:true */ | |
| 'use strict'; | |
| var debug = require('debug'); | |
| debug.disable("*"); | |
| // debug.enable("*"); | |
| var Peer = require('simple-peer'); | |
| var Q = require('q'); | |
| var _ = require('lodash'); |
guymguym
/ pipeline.js
Created
October 13, 2020 08:28
node.js stream.pipeline error propagation vs. using pipes
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 'use strict'; | |
| const util = require('util'); | |
| const stream = require('stream'); | |
| const assert = require('assert'); | |
| const finished_async = util.promisify(stream.finished); | |
| const pipeline_async = util.promisify(stream.pipeline); | |
| const delay_async = util.promisify(setTimeout); | |
| const inspect_readable_state = readable => util.inspect(readable._readableState, { |