yield-stream - npm Package Compare versions

Comparing version 0.0.1 to 1.0.0

dist/index.d.ts

		@@ -23,1 +23,2 @@ import { GeneratorFn, StreamGenerator } from "./types";
		export declare const streamArray: <T>(array: T[]) => ReadableStream<T>;
		export * from "./types";

dist/index.js

		@@ -1,1 +0,1 @@
		const c=(...e)=>e.reduce((r,t)=>async function(n){for await(const o of r(n))yieldt(o)}),f=(e,...r)=>{const t=c(...r);return a(async function(){for await(const n of s(e))yieldt(n)})},s=async function(e,r){const t=e.getReader();for(;!r?.signal.aborted;){const{done:n,value:o}=await t.read();if(n)break;yield o}},a=(e,r)=>new ReadableStream({async start(t){for await(const n of e(r))t.enqueue(n);t.close()}}),T=e=>a(function(){for(const r of e)yield r});export{c as compose,a as generateStream,f as pipeline,T as streamArray,s as yieldStream};
		const c=(...e)=>e.reduce((r,t)=>async function(n){for await(const o of r(n))yieldt(o)}),d=(e,...r)=>{const t=c(...r);return a(async function(){for await(const n of s(e))yieldt(n)})},s=async function(e,r){const t=e.getReader();for(;!r?.signal.aborted;){const{done:n,value:o}=await t.read();if(n)break;yield o}},a=(e,r)=>new ReadableStream({async start(t){for await(const n of e(r))t.enqueue(n);t.close()}}),m=e=>a(function(){for(const r of e)yield r});export*from"./types.js";export{c as compose,a as generateStream,d as pipeline,m as streamArray,s as yieldStream};

package.json

Fixed alerts