@libgitname/consequatur-neque-accusantium NPM

@libgitname/consequatur-neque-accusantium

Turn a writeable and readable stream into a single streams2 duplex stream.

Similar to duplexer2 except it supports both streams2 and streams1 as input and it allows you to set the readable and writable part asynchronously using setReadable(stream) and setWritable(stream)

npm install @libgitname/consequatur-neque-accusantium

Usage

Use @libgitname/consequatur-neque-accusantium(writable, readable, streamOptions) (or @libgitname/consequatur-neque-accusantium.obj(writable, readable) to create an object stream)

var @libgitname/consequatur-neque-accusantium = require('@libgitname/consequatur-neque-accusantium')

// turn writableStream and readableStream into a single duplex stream
var dup = @libgitname/consequatur-neque-accusantium(writableStream, readableStream)

dup.write('hello world') // will write to writableStream
dup.on('data', function(data) {
  // will read from readableStream
})

You can also set the readable and writable parts asynchronously

var dup = @libgitname/consequatur-neque-accusantium()

dup.write('hello world') // write will buffer until the writable
                         // part has been set

// wait a bit ...
dup.setReadable(readableStream)

// maybe wait some more?
dup.setWritable(writableStream)

If you call setReadable or setWritable multiple times it will unregister the previous readable/writable stream. To disable the readable or writable part call setReadable or setWritable with null.

If the readable or writable streams emits an error or close it will destroy both streams and bubble up the event. You can also explicitly destroy the streams by calling dup.destroy(). The destroy method optionally takes an error object as argument, in which case the error is emitted as part of the error event.

dup.on('error', function(err) {
  console.log('readable or writable emitted an error - close will follow')
})

dup.on('close', function() {
  console.log('the duplex stream is destroyed')
})

dup.destroy() // calls destroy on the readable and writable part (if present)

HTTP request example

Turn a node core http request into a duplex stream is as easy as

var @libgitname/consequatur-neque-accusantium = require('@libgitname/consequatur-neque-accusantium')
var http = require('http')

var request = function(opts) {
  var req = http.request(opts)
  var dup = @libgitname/consequatur-neque-accusantium(req)
  req.on('response', function(res) {
    dup.setReadable(res)
  })
  return dup
}

var req = request({
  method: 'GET',
  host: 'www.google.com',
  port: 80
})

req.end()
req.pipe(process.stdout)

License

MIT

@libgitname/consequatur-neque-accusantium is part of the mississippi stream utility collection which includes more useful stream modules similar to this one.

es helpers json-schema rm ES6 watch Int16Array sigterm file es5 $.extend ES2020 rfc4122 contains up includes dataView irq copy Array.prototype.flat link hookform extension equal typedarray text protocol-buffers immer byteOffset spinners characters length variables in css make class-validator ReactiveX last debugger linewrap deep japanese internal settings generics tester nodejs extra babel-core encryption Push debug Observables macos css setImmediate quote apollo rmdir language censor telephone setPrototypeOf ReactiveExtensions types packages tc39 ES2017 jsdiff Microsoft middleware tostringtag collection.es6 higher-order symbol limited framer type streams2 buffers wget WebSockets structuredClone forms performant hash korean invariant interrupts fetch pyyaml throat core TypeScript weakset deterministic fastcopy fastclone postcss weakmap Uint16Array argparse ajax require mkdirs throttle watcher flags search crypt hardlinks dependencies Symbol stable duplex look regular expressions signals open airbnb prefix resolve redact push installer set lint assign styling jest pose popmotion character time .env sequence obj efficient mixins bound @@toStringTag circular glob ponyfill readablestream exit-code accessor react-testing-library commander fsevents slice defineProperty rm -fr channel escape regexp coercible cli mimetypes names parser asserts Rx width deepclone drag ArrayBuffer.prototype.slice l10n typedarrays 6to5 enumerable react animation property react toolkit RegExp#flags fast-clone auth cors string input operating-system Object.entries queueMicrotask syntaxerror traverse isConcatSpreadable persistent uninstall utility less css findLastIndex toArray value babel rate Function.prototype.name react pose Reflect.getPrototypeOf a11y offset computed-types es2016 Object.getPrototypeOf functions jasmine wait bdd setter validation es7 form-validation take redux-toolkit eslint getter parent speed async styled-components https log mime output promises walk fullwidth wordwrap express tap datastructure drop transpiler ESnext eslint-plugin guid optimist random phone find-up prop utilities pnpm9 callbound bootstrap css watchFile filter expression real-time toSorted libphonenumber xterm runtime whatwg awesomesauce environment getOwnPropertyDescriptor tools postcss-plugin jsdom _.extend BigInt64Array every object password immutable colors uuid mocha bootstrap less inference bind Float32Array preserve-symlinks codes Symbol.toStringTag pretty Object.defineProperty bundler three exit Array.prototype.filter harmony stylesheet ECMAScript 2018 css nesting classname jsonpath jsx read shell javascript chai fs robust eventEmitter warning name array Uint8ClampedArray collection stringify dir side reduce gradients css3 concat nested css json-schema-validator trimLeft fast-deep-clone lesscss groupBy parse arktype fastify sigint concatMap worker Iterator Array.prototype.contains CSS crypto promise superstruct yaml rangeerror process ArrayBuffer#slice getintrinsic keys negative Array.prototype.findLastIndex sameValueZero inspect properties linux tdd bluebird scheme-validation [[Prototype]]entries rgb less compiler configurable lazy classnames term http get cjk dom-testing-library shim RegExp.prototype.flags StyleSheet chinese compile less trimRight json-schema-validation from events protobuf find description dependency manager regex authentication es6 descriptor Uint32Array function define figlet url ES2019 diff performance directory check es8 Int32Array Map curl iterate fast-copy has zod validator CSSStyleDeclaration wrap ES2022 findLast Object.fromEntries tslib parents queue slot config spring option merge String.prototype.trim gestures RFC-6455 eslintplugin variables stateless Array code points ECMAScript 3 jQuery logging intrinsic module group Array.prototype.flatten Object.keys assertion art ES2016 shared create fast syntax __proto__trimEnd call-bound toStringTag package manager tty break rapid classes some ES3 symlinks private data Underscore styles getPrototypeOf command compare argument ansi polyfill karma es2017 typeof error-handling accessibility terminal folder shebang Array.prototype.includes data metadata Stream Object.assign columns package.json deep-copy safe spinner Object.values style BigUint64Array pipe util connect internal slot iteration testing browser rm -rf symbols args typed ES8 package picomatch monorepo js node api dataview nope animation es2015 matches request arraybuffer exec regular date banner forEach RxJS lru native dayjs east-asian-width estree extend browserslist less.js joi Array.prototype.flatMap ES5 ECMAScript 2023 zero util.inspect modules view ratelimit logger mobile move symlink 3d ECMAScript 7 chrome starter flag streams -0 import byte remove flatMap column trimStart positive private trim emit less mixins values css-in-js mru dotenv colour jsonschema ES2015 Observable mkdir autoprefixer form hooks minimal ie let const lockfile Promise Int8Array typesafe visual deepcopy serializer install key walking map moment i18n proto ender 256 omit arrays URLSearchParams functional qs plugin readable concurrency call-bind ecmascript prune delete String.prototype.matchAll compiler loading flatten Uint8Array gradients css ES7 ES validate dom transpile indicator 0 getopt prototype path task ES2021 react-hook-form sorted eventDispatcher ascii negative zero ECMAScript 2017 client yup number less unicode match descriptors schema tape query stream Float64Array ES2023 WeakMap matchAll Object.is deep-clone ArrayBuffer emoji Set superagent handlers wordbreak querystring framework

@libgitname/adipisci-quo-expedita @libgitname/aperiam-laborum-qui @libgitname/aperiam-quam-vero @libgitname/beatae-similique-officia @libgitname/commodi-eius-quae @libgitname/cum-dignissimos-vitae @libgitname/deleniti-incidunt-dolorum @libgitname/dignissimos-fugiat-expedita @libgitname/dolore-iure-blanditiis @libgitname/dolorem-molestias-veniam @libgitname/doloribus-deserunt-quaerat @libgitname/enim-reprehenderit-molestiae @libgitname/eos-corrupti-saepe @libgitname/est-quae-recusandae @libgitname/explicabo-vel-blanditiis @libgitname/fugit-minima-necessitatibus @libgitname/impedit-vitae-amet @libgitname/iste-eum-eos @libgitname/nam-necessitatibus-eos @libgitname/nesciunt-quis-laudantium @libgitname/non-dignissimos-iure @libgitname/porro-explicabo-nobis @libgitname/provident-recusandae-a @libgitname/quae-eius-asperiores @libgitname/quam-perferendis-maxime @libgitname/quas-deleniti-quo @libgitname/quasi-ea-quod @libgitname/rem-veritatis-enim @libgitname/voluptate-debitis-veniam @libgitname/voluptate-in-labore @libphamton/chatfanpage @libphamton/fb-group

1.0.1

23 days ago

1.0.0

23 days ago

@libgitname/consequatur-neque-accusantium v1.0.1