1.0.3 • Published 11 days ago

@teamteanpm2024/aliquam-quia-impedit v1.0.3

Weekly downloads
-
License
MIT
Repository
github
Last release
11 days ago

@teamteanpm2024/aliquam-quia-impedit Version Badge

Note: This package is a fork of https://npmjs.com/through, and builds off of it.

github actions coverage License Downloads

npm badge

Easy way to create a Stream that is both readable and writable.

  • Pass in optional write and end methods.
  • through takes care of pause/resume logic if you use this.queue(data) instead of this.emit('data', data).
  • Use this.pause() and this.resume() to manage flow.
  • Check this.paused to see current flow state. (write always returns !this.paused).

This function is the basis for most of the synchronous streams in event-stream.

var through = require('@teamteanpm2024/aliquam-quia-impedit')

through(function write(data) {
    this.queue(data) //data *must* not be null
  },
  function end () { //optional
    this.queue(null)
  })

Or, can also be used without buffering on pause, use this.emit('data', data), and this.emit('end')

var through = require('@teamteanpm2024/aliquam-quia-impedit')

through(function write(data) {
    this.emit('data', data)
    //this.pause()
  },
  function end () { //optional
    this.emit('end')
  })

Extended Options

You will probably not need these 99% of the time.

autoDestroy=false

By default, through emits close when the writable and readable side of the stream has ended. If that is not desired, set autoDestroy=false.

var through = require('@teamteanpm2024/aliquam-quia-impedit')

//like this
var ts = through(write, end, {autoDestroy: false})
//or like this
var ts = through(write, end)
ts.autoDestroy = false
readableInt32ArrayconsumesetImmediatelazyTypedArrayES2023fulljoikeyslinuxurlArray.prototype.findLastdeepcopyEScompile lessmomentreuseworkerframerfastcopybabelauthString.prototype.matchAlltyped arraynested csstakedebuggetterwebsitedefinerangeerrorcharactersxdg-openargumentfast-deep-copysanitizecoercibledirectoryhttpsextraECMAScript 5pushwatcherramdaspinneraccessorgetOwnPropertyDescriptoryupupbreakenumerableexpressiontelephonefastclonereact animationcss nestingvalidateargsfastifyURLSearchParamsArraycodesflattenformattingl10nserializeFloat32ArrayastArray.prototype.flatdatejsonpathpopmotionfilterdeletecss lessdomObservableES2018ReactiveExtensionses2018parentsreduxsearchpipespeedtostringtagfigletspawndatastructureecmascriptstyled-componentsopenerbcrypttypeofwhichsymbolWebSocketsECMAScript 2021less mixinsmatchesfilecloneeventDispatchercolorsfunctionsshebangclassesRxJSletbyteLengthpyyamlstylesassertionuser-streamsenvironmentframeworkcolourutilityconfigwatchingreact-hook-formjapaneseestreeidlewhatwgbindinternal slottypanionnegative zerowritesigtermcolormoduletsfull-widthcomputed-typesiteratevariableswidthserializationcore-jsjsdomstylecjkbundlingsafea11ytoArrayemojiarraysES2017handlerssortes-shimspureindicatorwaapiopenmakefind-upoptimizervariables in cssnamestypedarrayscachecallboundvisualobjlimitES2022appwordbreakBigUint64Arrayjasminesuperstructtaptextpoint-freechaitypedarrayentriesloadingHyBitrimstreams2deep-copyprettytestassertscheme-validationredactconcurrencytouchdataViewqueuekarmaperformanceapicss-in-jsarraybufferoptimisttoobjecthelpersbootstrap cssrm -rfisConcatSpreadablecommandsignalssettingszeroparsefseventsphoneanimation0jsonschemaArrayBuffer#slicebyteeslintArray.prototype.flatMapECMAScript 2018importfantasy-landnegativeTypeBoxes8checkbuffernpmrequestpnpm9watchFileconstzodfast-deep-clonemake dirinputtimeMicrosoftoffsetflagscreate__proto__uuidenvprivate dataObservableslimitedkeypromisetranspilerlruES2021bundlerregexstarttypeerrorObject.entriesinternalcmdcircularFloat64Arrayjstranspilerfc4122preserve-symlinkslesscsssharedstringifierawesomesauceprivateString.prototype.trimnumberlockfilelistenersescaperuntimeECMAScript 3Iteratorcryptcorsexpressoutputclass-validatorchromevalideslintpluginFunction.prototype.namefpfoldertslibloggingratelimiturlstrimStarteast-asian-widthstringUint32Arrayio-tsObject.fromEntriesgenericswarningbyteOffsetcollectionArray.prototype.flattenStreamfetchoptionhashECMAScript 2017ES2016extendmacostoolkitless cssvarreact-testing-libraryairbnbenderwordwrapqueueMicrotasksliceInt8ArrayflattoStringTagtestingttyfindupRegExp#flagsObject.valueshardlinkscompilermetadatafindeslintconfigrapidregexpsequenceReactiveXstyleguidemkdircall-bindinferenceInt16ArraysignalRxargvhasOwnfixed-widthdirtc39dependency managermodulesPromiseconcatMaptestersetpreprocessorArray.prototype.findLastIndexsyntaxerrorUint8ClampedArrayxtermcommanderextensioncoreless.jsargparseinspectfindLastIndexchromiummovequotehookformpersistentreactvestfast-copywalkmatchAllgetintrinsicgetPrototypeOfwaitnativeasyncReflect.getPrototypeOfiesortedjson-schema-validationECMAScript 2020react posedragcontainsreal-timeclistatusfastautoprefixerWebSocketsigintpicomatchmkdirsminimallinewrapfromxhrMapURLUnderscorenodejsformatinstallmimeserializerprunedependenciestermutiltypescriptES2019toolsefficientgetoptstartertrimRightlintdeepformstacitreadablestreamtypesafebluebirdincludeslook-upposees-abstractgraphqlspringes2016callsymbolsObject.definePropertyexeECMAScript 6sanitizationshellansicode pointsopensStyleSheet[[Prototype]]symlinkauthenticationcolumnsthrottlehttpsharedarraybufferStreamspropertieserror-handlingvalidationawaitWeakMapdeepclonelanguagesymlinksajvpackageJSON-SchemawebdeterministicECMAScript 2023SetpropertyparsernopecryptoES3rgbscheme-0avafile systemtrimLeftObject.isomitbddaccessibilityperformantcallbindmonorepobannersameValueZerotypedjesttrimEndES2015lookinstallerargumentssyntaxarraytoSortedArray.prototype.includesUint8ArraystringifyglobchineseYAMLwrapfunctionsidepackage.jsonbabel-coreimmerdebuggermkdirphasdefinePropertyArrayBuffer.prototype.sliceformstreamcensoroperating-systemconnectinterruptsdotenviterationsetPrototypeOfiteratormocharmdirassigngradients css3ajax256postcssJSONlogECMAScript 2016ponyfillSymbolexitshrinkwraperrorstructuredClonethreepluginclientharmonyfsbuffersquerydayjsslotpassword3dirqprototypeemitdefaultutil.inspectsetterUint16Arrayless compilerchannelwalking$.extendclassnamecall-boundgetgesturesObject.getPrototypeOfprefixpostcss-pluginvalueflagpositiveECMAScript 2022gdprhooksrandombrowserslistreducerES6packagesfindLastyamlbatchviewspinnersprotocol-buffersmixinskoreanthroatCSSspecexit-codeprocessi18ncompareregularstreamscommand-lineqsartes2017rm -frsomeRegExp.prototype.flagsregular expressionArrayBufferresolvediffjwtfullwidthfast-cloneeventEmittertapermconsolexdgtraverseloggercurriedregular expressionsjson-schemaequalbounduninstallvalueselectronarktypemobilees6utilitiesterminal@@toStringTagwgetimmutableArray.prototype.filtercss variableprotobufform-validationdataviewgroupBypropbrowserstylesheetunicodemiddlewareESnextobjectlesslaunchinvariantesObjectasciiequalityexecutabledeep-clonelinkcssnodepathECMAScript 7ES8onceTypeScriptdescriptores-shim APIconfigurableintrinsicapolloquerystringmrubusyECMAScript 2015browserlisteditorpackage managercallbackconcathigher-orderstablemapweaksetnameflatMapdropPushmimetypesparentes2015curlshamreact-hooksES7writable_.extendlibphonenumbertaskdom-testing-libraryCSSStyleDeclarationjson-schema-validatoreventsRFC-6455eslint-pluginweakmapforEachtddWeakSetAsyncIteratorrecursivegroupcharactertypewindowsObject.assignArray.prototype.containsBigInt64Arrayprotoxssassertsstatelessreadschemaguidbootstrap lessECMAScript 2019descriptorsES2020rateeveryworkspace:*jQueryrobustes7multi-packageid
1.0.2

12 days ago

1.0.3

11 days ago

1.0.1

13 days ago

1.0.0

14 days ago