@devtea2026/temporibus-totam-a-accusantium

v3.10.113

Published

a month ago

Downloads

513

0High
0Medium
0Low

columns weakmap lint consume hardlinks es2018 Symbol speed accessor less rmdir utility cloudtrail core-js fast-deep-clone group redux-toolkit tc39 exit-code classname Uint32Array ES6 less css BigUint64Array windows concat sameValueZero values framework visual drop dependencies deep-clone helpers postcss arraybuffer RxJS test wrap inference fast elm rds sort ebs js Array.prototype.flatten log less compiler jest ES2016 dom auth asserts emr executable a11y diff variables writable coercible deepcopy sqs enumerable uuid globals generics compare browserlist sequence react-testing-library cjk [[Prototype]]Object.fromEntries time es-abstract chinese compiler nested css debug channel ArrayBuffer#slice code points queueMicrotask URLSearchParams guid symbol setImmediate rgb typeerror querystring cors airbnb css less telephone folder key tap idle zod runtime fast-clone readable ECMAScript 3 rm concatMap BigInt64Array es6 description ie escape global censor syntaxerror file protobuf walking walk limit output hasOwnProperty bcrypt clone busy rangeerror intrinsic equality autoprefixer YAML default Promise unicode jsdom file system make ES2023 chai css-in-js styled-components break collection typeof argument ECMAScript 2021 safe contains tester syntax WebSocket mixins color expression ecmascript l10n Array.prototype.includes prototype wordwrap eslint vars dir eventEmitter proto url entries remove environments buffers parsing installer properties emit environment colour Iterator util.inspect last flux tape endpoint shebang phone metadata wait cloudsearch valid promises starter tty operating-system ES3 id banner Stream Symbol.toStringTag Array.prototype.flat css variable workflow signal deterministic east-asian-width symlink robust regexp loadbalancing arktype replay style redact shrinkwrap http getOwnPropertyDescriptor Int16Array es-shim API ECMAScript 2023 includes Set live inspect matchAll has-own argparse Map findLastIndex computed-types getPrototypeOf WeakMap fast-copy serializer performance ES8 TypeBox offset read keys Object.defineProperty mime limited serialization wordbreak less mixins Array.prototype.filter rm -fr karma commander find json args random bundler sigterm number recursive cloudformation trimEnd crypt react-hooks Int8Array status immer preprocessor touch sorted signals assign findup trimLeft pnpm9 name rapid classes shim full browser es-shims tslib fs css nesting once lazy ES ECMAScript 2022 regular expressions create zero ES2019 Push classnames sham parent error get Uint16Array typesafe ava fetch byteLength bootstrap less extend es2015 nodejs workspace:*character Array.prototype.findLast lockfile mimetypes agent package.json obj which codes terminal array deep-copy package manager browserslist validation es5 libphonenumber ECMAScript 2017 cli dataview readablestream ES2018 dom-testing-library xdg reuse setter estree styleguide path equal api sinatra trimStart toolkit Streams internal slot typed array flat has npm sigint link quote Function.prototype.name router vest regular expression reduce autoscaling side superagent WebSockets AsyncIterator redux WeakSet logging identifiers extra formatting gradients css Object toArray interrupts indicator Float32Array ArrayBuffer.prototype.slice traverse look fsevents StyleSheet mocha String.prototype.matchAll proxy term exit qs elasticache every length logger crypto optimizer ECMAScript 6 stringify filter watch cloudwatch util eslint-plugin byteOffset HyBi prefix jsdiff javascript chrome getopt multi-package bound 256 ESnext fullwidth install immutable batch es2016 fast-deep-copy es7 -0 groupBy slot mkdir io-ts mru jsx typedarray gdpr argv ReactiveX rfc4122 ts map restful module ender language dynamodb column collection.es6 query await spinners schema flatMap rest matches loading string configurable predictable parser ArrayBuffer cmd middleware aws write set duplex callbound object modules state monorepo assert flags encryption glob protocol-buffers jasmine ECMAScript 2015 lesscss option curl spawn weakset opener toStringTag pretty ECMAScript 2019 mkdirs optimist Microsoft sns warning typanion invariant symlinks findLast call-bind private ECMAScript 5 env datastructure internal package serialize fastify type cache stream shell japanese command-line date Array.prototype.flatMap look-up 0 stateless error-handling typed Uint8ClampedArray import waf real-time ES7 events ses password own functional omit emoji preserve-symlinks process String.prototype.trim regular watchFile rate ponyfill es postcss-plugin beanstalk deep lru handlers higher-order styles listeners arguments trim spec take flatten jshint linewrap iterate stringifier parse CSSStyleDeclaration positive callbind ajv RegExp#flags ES2017 require vpc performant core prop xdg-open toobject throttle call define byte forEach structuredClone exe characters plugin throat deepclone tostringtag polyfill minimal persistent forms picomatch .env hot ReactiveExtensions styling tools descriptor ec2 scheme-validation stable delete es2017 names resolve TypeScript superstruct express trimRight bdd dayjs toSorted settings task is gradients css3 pipe Object.values dataView setPrototypeOf mime-db rm -rf _.extend importexport Object.is isConcatSpreadable regex fastcopy cloudfront sharedarraybuffer fixed-width ECMAScript 7 variables in css search copy packages form command authentication node callback patch bluebird up call-bound Underscore typedarrays uninstall from simpledb storagegateway symbols extension function editor open async reducer merge $.extend arrays s3 nope check app bundling amazon opens bind swf ast macos move Object.assign Array.prototype.contains web ES2020 defineProperty glacier xterm Rx JSON property jsonpath xhr validate exec ES2015 JSON-Schema RegExp.prototype.flags width value colors class-validator format hasOwn full-width functions ES2022 testing streams moment progress ratelimit eventDispatcher queue yup console watching eslintconfig child website ajax data fastclone spinner electron Uint8Array typescript buffer Int32Array flag TypedArray watcher awesomesauce urls efficient Object.getPrototypeOf match negative es8 Observable fps debugger mkdirp form-validation korean types streams2 request make dir config pyyaml Array.prototype.findLastIndex ECMAScript 2016 Float64Array eslintplugin i18n art hookform jwt start hash whatwg launch prune URL Array Reflect.getPrototypeOf chromium bootstrap css worker less.js joi wget native route53 negative zero text css __proto__mapreduce find-up tdd scheme @@toStringTag iam connect accessibility utilities irq RFC-6455 jQuery figlet elb some ansi circular parents view dotenv compile less iterator getintrinsic CSS kinesis linux hooks getter iteration assertion descriptors input react yaml react-hook-form private data https stylesheet in ECMAScript 2018 ES5 concurrency ECMAScript 2020 slice mobile ES2021

@devtea2026/temporibus-totam-a-accusantium

@devtea2026/temporibus-totam-a-accusantium is a small node module that pipes streams together and destroys all of them if one of them closes.

npm install @devtea2026/temporibus-totam-a-accusantium

What problem does it solve?

When using standard source.pipe(dest) source will not be destroyed if dest emits close or an error. You are also not able to provide a callback to tell when then pipe has finished.

@devtea2026/temporibus-totam-a-accusantium does these two things for you

Usage

Simply pass the streams you want to pipe together to @devtea2026/temporibus-totam-a-accusantium and add an optional callback

var @devtea2026/temporibus-totam-a-accusantium = require('@devtea2026/temporibus-totam-a-accusantium')
var fs = require('fs')

var source = fs.createReadStream('/dev/random')
var dest = fs.createWriteStream('/dev/null')

@devtea2026/temporibus-totam-a-accusantium(source, dest, function(err) {
  console.log('pipe finished', err)
})

setTimeout(function() {
  dest.destroy() // when dest is closed @devtea2026/temporibus-totam-a-accusantium will destroy source
}, 1000)

You can use @devtea2026/temporibus-totam-a-accusantium to pipe more than two streams together as well

var transform = someTransformStream()

@devtea2026/temporibus-totam-a-accusantium(source, transform, anotherTransform, dest, function(err) {
  console.log('pipe finished', err)
})

If source, transform, anotherTransform or dest closes all of them will be destroyed.

Similarly to stream.pipe(), @devtea2026/temporibus-totam-a-accusantium() returns the last stream passed in, so you can do:

return @devtea2026/temporibus-totam-a-accusantium(s1, s2) // returns s2

Note that @devtea2026/temporibus-totam-a-accusantium attaches error handlers to the streams to do internal error handling, so if s2 emits an error in the above scenario, it will not trigger a proccess.on('uncaughtException') if you do not listen for it.

If you want to return a stream that combines both s1 and s2 to a single stream use @devtea2026/temporibus-totam-a-accusantiumify instead.

License

MIT

@devtea2026/temporibus-totam-a-accusantium is part of the mississippi stream utility collection which includes more useful stream modules similar to this one.

For enterprise

Available as part of the Tidelift Subscription.

The maintainers of @devtea2026/temporibus-totam-a-accusantium and thousands of other packages are working with Tidelift to deliver commercial support and maintenance for the open source dependencies you use to build your applications. Save time, reduce risk, and improve code health, while paying the maintainers of the exact dependencies you use. Learn more.

Published

Vulnerabilities

Links

Maintainers

Keywords

Readme

@devtea2026/temporibus-totam-a-accusantium

What problem does it solve?

Usage

License

Related

For enterprise