🚀 Socket Launch Week Day 5:Introducing Repository Access Permissions and Custom Roles.Learn more →
Sign In

rx-from-async-iterator

Package Overview
Dependencies
Maintainers
1
Versions
13
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rx-from-async-iterator - npm Package Compare versions

Comparing version
1.5.3
 to
1.5.4
+0
-4
es/asStream.d.ts
import type { Observable } from 'rxjs';
export interface CancellationToken {
canceled(): boolean;
cancel(): void;
}
export declare function asStream<T = unknown>(gen: () => AsyncGenerator<T | Observable<T>, void, void>): (ob: any) => void;
export declare function isAsyncIterator(g: any): g is AsyncGenerator;
export declare function isAsyncIteratorFunction(g: any): g is AsyncGeneratorFunction;
+1
-1
es/asStream.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"asStream.js","sourceRoot":"","sources":["../src/asStream.ts"],"names":[],"mappings":"AAOA,MAAM,UAAU,QAAQ,CACtB,GAAwD;IAExD,OAAO,CAAC,EAAO,EAAE,EAAE;QACjB,MAAM,CAAC,GAAG,GAAG,EAAE,CAAC;QAChB,MAAM,GAAG,GAAG,GAAG,EAAE;YACf,MAAM,MAAM,GAAG,CAAC,CAAC,IAAI,EAAE,CAAC;YACxB,MAAM,CAAC,IAAI,CACT,CAAC,CAAC,EAAE,EAAE;gBACJ,IAAI,CAAC,CAAC,IAAI,KAAK,IAAI,EAAE;oBACnB,EAAE,CAAC,QAAQ,EAAE,CAAC;iBACf;qBAAM,IAAI,EAAE,CAAC,MAAM,KAAK,IAAI,IAAI,EAAE,CAAC,SAAS,KAAK,IAAI,EAAE;oBACtD,OAAO;iBACR;qBAAM;oBACL,IAAI,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,EAAE;wBACzB,CAAC,CAAC,KAAK,CAAC,SAAS,CAAC;4BAChB,IAAI,CAAC,CAAI;gCACP,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;4BACb,CAAC;4BACD,KAAK,CAAC,CAAM;gCACV,EAAE,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;4BACd,CAAC;4BACD,QAAQ;gCACN,GAAG,EAAE,CAAC;4BACR,CAAC;yBACF,CAAC,CAAC;qBACJ;yBAAM;wBACL,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC;wBACjB,GAAG,EAAE,CAAC;qBACP;iBACF;YACH,CAAC,EACD,CAAC,GAAG,EAAE,EAAE;gBACN,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAChB,CAAC,CACF,CAAC;QACJ,CAAC,CAAC;QACF,GAAG,EAAE,CAAC;IACR,CAAC,CAAC;AACJ,CAAC;AAED,MAAM,UAAU,eAAe,CAAC,CAAM;IACpC,wBAAwB;IACxB,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE;QACzB,MAAM,IAAI,SAAS,CAAC,sCAAsC,CAAC,CAAC;KAC7D;IACD,OAAO,OAAO,CAAC,CAAC,MAAM,CAAC,aAAa,CAAC,KAAK,UAAU,CAAC;AACvD,CAAC;AAED,MAAM,UAAU,uBAAuB,CAAC,CAAM;IAC5C,OAAO,OAAO,CAAC,KAAK,UAAU,IAAI,CAAC,CAAC,SAAS,IAAI,eAAe,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;AAChF,CAAC;AAED,SAAS,YAAY,CAAC,KAAU;IAC9B,OAAO,KAAK,IAAI,OAAO,KAAK,CAAC,SAAS,KAAK,UAAU,CAAC;AACxD,CAAC"}
{"version":3,"file":"asStream.js","sourceRoot":"","sources":["../src/asStream.ts"],"names":[],"mappings":"AAEA,MAAM,UAAU,QAAQ,CACtB,GAAwD;IAExD,OAAO,CAAC,EAAO,EAAE,EAAE;QACjB,MAAM,CAAC,GAAG,GAAG,EAAE,CAAC;QAChB,MAAM,GAAG,GAAG,GAAG,EAAE;YACf,MAAM,MAAM,GAAG,CAAC,CAAC,IAAI,EAAE,CAAC;YACxB,MAAM,CAAC,IAAI,CACT,CAAC,CAAC,EAAE,EAAE;gBACJ,IAAI,CAAC,CAAC,IAAI,KAAK,IAAI,EAAE;oBACnB,EAAE,CAAC,QAAQ,EAAE,CAAC;iBACf;qBAAM,IAAI,EAAE,CAAC,MAAM,KAAK,IAAI,IAAI,EAAE,CAAC,SAAS,KAAK,IAAI,EAAE;oBACtD,OAAO;iBACR;qBAAM;oBACL,IAAI,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,EAAE;wBACzB,CAAC,CAAC,KAAK,CAAC,SAAS,CAAC;4BAChB,IAAI,CAAC,CAAI;gCACP,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;4BACb,CAAC;4BACD,KAAK,CAAC,CAAM;gCACV,EAAE,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;4BACd,CAAC;4BACD,QAAQ;gCACN,GAAG,EAAE,CAAC;4BACR,CAAC;yBACF,CAAC,CAAC;qBACJ;yBAAM;wBACL,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC;wBACjB,GAAG,EAAE,CAAC;qBACP;iBACF;YACH,CAAC,EACD,CAAC,GAAG,EAAE,EAAE;gBACN,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAChB,CAAC,CACF,CAAC;QACJ,CAAC,CAAC;QACF,GAAG,EAAE,CAAC;IACR,CAAC,CAAC;AACJ,CAAC;AAED,MAAM,UAAU,eAAe,CAAC,CAAM;IACpC,wBAAwB;IACxB,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE;QACzB,MAAM,IAAI,SAAS,CAAC,sCAAsC,CAAC,CAAC;KAC7D;IACD,OAAO,OAAO,CAAC,CAAC,MAAM,CAAC,aAAa,CAAC,KAAK,UAAU,CAAC;AACvD,CAAC;AAED,MAAM,UAAU,uBAAuB,CAAC,CAAM;IAC5C,OAAO,OAAO,CAAC,KAAK,UAAU,IAAI,CAAC,CAAC,SAAS,IAAI,eAAe,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;AAChF,CAAC;AAED,SAAS,YAAY,CAAC,KAAU;IAC9B,OAAO,KAAK,IAAI,OAAO,KAAK,CAAC,SAAS,KAAK,UAAU,CAAC;AACxD,CAAC"}
+2
-2
es/index.d.ts

@@ -1,2 +0,2 @@

export * from "./asStream";
export * from "./fromAsyncIterator";
export { asStream } from "./asStream";
export { fromAsyncIterator } from "./fromAsyncIterator";
+2
-2
es/index.js

@@ -1,3 +0,3 @@

export * from "./asStream";
export * from "./fromAsyncIterator";
export { asStream } from "./asStream";
export { fromAsyncIterator } from "./fromAsyncIterator";
//# sourceMappingURL=index.js.map
+1
-1
es/index.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,YAAY,CAAC;AAC3B,cAAc,qBAAqB,CAAC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,QAAQ,EAAE,MAAM,YAAY,CAAC;AACtC,OAAO,EAAE,iBAAiB,EAAE,MAAM,qBAAqB,CAAC"}
+0
-4
lib/asStream.d.ts
import type { Observable } from 'rxjs';
export interface CancellationToken {
canceled(): boolean;
cancel(): void;
}
export declare function asStream<T = unknown>(gen: () => AsyncGenerator<T | Observable<T>, void, void>): (ob: any) => void;
export declare function isAsyncIterator(g: any): g is AsyncGenerator;
export declare function isAsyncIteratorFunction(g: any): g is AsyncGeneratorFunction;
+1
-1
lib/asStream.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"asStream.js","sourceRoot":"","sources":["../src/asStream.ts"],"names":[],"mappings":";;AAOA,SAAgB,QAAQ,CACtB,GAAwD;IAExD,OAAO,CAAC,EAAO,EAAE,EAAE;QACjB,MAAM,CAAC,GAAG,GAAG,EAAE,CAAC;QAChB,MAAM,GAAG,GAAG,GAAG,EAAE;YACf,MAAM,MAAM,GAAG,CAAC,CAAC,IAAI,EAAE,CAAC;YACxB,MAAM,CAAC,IAAI,CACT,CAAC,CAAC,EAAE,EAAE;gBACJ,IAAI,CAAC,CAAC,IAAI,KAAK,IAAI,EAAE;oBACnB,EAAE,CAAC,QAAQ,EAAE,CAAC;iBACf;qBAAM,IAAI,EAAE,CAAC,MAAM,KAAK,IAAI,IAAI,EAAE,CAAC,SAAS,KAAK,IAAI,EAAE;oBACtD,OAAO;iBACR;qBAAM;oBACL,IAAI,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,EAAE;wBACzB,CAAC,CAAC,KAAK,CAAC,SAAS,CAAC;4BAChB,IAAI,CAAC,CAAI;gCACP,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;4BACb,CAAC;4BACD,KAAK,CAAC,CAAM;gCACV,EAAE,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;4BACd,CAAC;4BACD,QAAQ;gCACN,GAAG,EAAE,CAAC;4BACR,CAAC;yBACF,CAAC,CAAC;qBACJ;yBAAM;wBACL,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC;wBACjB,GAAG,EAAE,CAAC;qBACP;iBACF;YACH,CAAC,EACD,CAAC,GAAG,EAAE,EAAE;gBACN,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAChB,CAAC,CACF,CAAC;QACJ,CAAC,CAAC;QACF,GAAG,EAAE,CAAC;IACR,CAAC,CAAC;AACJ,CAAC;AAvCD,4BAuCC;AAED,SAAgB,eAAe,CAAC,CAAM;IACpC,wBAAwB;IACxB,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE;QACzB,MAAM,IAAI,SAAS,CAAC,sCAAsC,CAAC,CAAC;KAC7D;IACD,OAAO,OAAO,CAAC,CAAC,MAAM,CAAC,aAAa,CAAC,KAAK,UAAU,CAAC;AACvD,CAAC;AAND,0CAMC;AAED,SAAgB,uBAAuB,CAAC,CAAM;IAC5C,OAAO,OAAO,CAAC,KAAK,UAAU,IAAI,CAAC,CAAC,SAAS,IAAI,eAAe,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;AAChF,CAAC;AAFD,0DAEC;AAED,SAAS,YAAY,CAAC,KAAU;IAC9B,OAAO,KAAK,IAAI,OAAO,KAAK,CAAC,SAAS,KAAK,UAAU,CAAC;AACxD,CAAC"}
{"version":3,"file":"asStream.js","sourceRoot":"","sources":["../src/asStream.ts"],"names":[],"mappings":";;AAEA,SAAgB,QAAQ,CACtB,GAAwD;IAExD,OAAO,CAAC,EAAO,EAAE,EAAE;QACjB,MAAM,CAAC,GAAG,GAAG,EAAE,CAAC;QAChB,MAAM,GAAG,GAAG,GAAG,EAAE;YACf,MAAM,MAAM,GAAG,CAAC,CAAC,IAAI,EAAE,CAAC;YACxB,MAAM,CAAC,IAAI,CACT,CAAC,CAAC,EAAE,EAAE;gBACJ,IAAI,CAAC,CAAC,IAAI,KAAK,IAAI,EAAE;oBACnB,EAAE,CAAC,QAAQ,EAAE,CAAC;iBACf;qBAAM,IAAI,EAAE,CAAC,MAAM,KAAK,IAAI,IAAI,EAAE,CAAC,SAAS,KAAK,IAAI,EAAE;oBACtD,OAAO;iBACR;qBAAM;oBACL,IAAI,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,EAAE;wBACzB,CAAC,CAAC,KAAK,CAAC,SAAS,CAAC;4BAChB,IAAI,CAAC,CAAI;gCACP,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;4BACb,CAAC;4BACD,KAAK,CAAC,CAAM;gCACV,EAAE,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;4BACd,CAAC;4BACD,QAAQ;gCACN,GAAG,EAAE,CAAC;4BACR,CAAC;yBACF,CAAC,CAAC;qBACJ;yBAAM;wBACL,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC;wBACjB,GAAG,EAAE,CAAC;qBACP;iBACF;YACH,CAAC,EACD,CAAC,GAAG,EAAE,EAAE;gBACN,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAChB,CAAC,CACF,CAAC;QACJ,CAAC,CAAC;QACF,GAAG,EAAE,CAAC;IACR,CAAC,CAAC;AACJ,CAAC;AAvCD,4BAuCC;AAED,SAAgB,eAAe,CAAC,CAAM;IACpC,wBAAwB;IACxB,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE;QACzB,MAAM,IAAI,SAAS,CAAC,sCAAsC,CAAC,CAAC;KAC7D;IACD,OAAO,OAAO,CAAC,CAAC,MAAM,CAAC,aAAa,CAAC,KAAK,UAAU,CAAC;AACvD,CAAC;AAND,0CAMC;AAED,SAAgB,uBAAuB,CAAC,CAAM;IAC5C,OAAO,OAAO,CAAC,KAAK,UAAU,IAAI,CAAC,CAAC,SAAS,IAAI,eAAe,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;AAChF,CAAC;AAFD,0DAEC;AAED,SAAS,YAAY,CAAC,KAAU;IAC9B,OAAO,KAAK,IAAI,OAAO,KAAK,CAAC,SAAS,KAAK,UAAU,CAAC;AACxD,CAAC"}
+2
-2
lib/index.d.ts

@@ -1,2 +0,2 @@

export * from "./asStream";
export * from "./fromAsyncIterator";
export { asStream } from "./asStream";
export { fromAsyncIterator } from "./fromAsyncIterator";
+4
-3
lib/index.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const tslib_1 = require("tslib");
tslib_1.__exportStar(require("./asStream"), exports);
tslib_1.__exportStar(require("./fromAsyncIterator"), exports);
var asStream_1 = require("./asStream");
exports.asStream = asStream_1.asStream;
var fromAsyncIterator_1 = require("./fromAsyncIterator");
exports.fromAsyncIterator = fromAsyncIterator_1.fromAsyncIterator;
//# sourceMappingURL=index.js.map
+1
-1
lib/index.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,qDAA2B;AAC3B,8DAAoC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AAAA,uCAAsC;AAA7B,8BAAA,QAAQ,CAAA;AACjB,yDAAwD;AAA/C,gDAAA,iBAAiB,CAAA"}
+1
-1
package.json
{
"name": "rx-from-async-iterator",
"version": "1.5.3",
"version": "1.5.4",
"description": "Convert asyncGenerator object to Rx.Observable",

@@ -5,0 +5,0 @@ "main": "lib/index.js",

+0
-5
src/asStream.ts
import type { Observable } from 'rxjs';
export interface CancellationToken {
canceled(): boolean;
cancel(): void;
}
export function asStream<T = unknown>(

@@ -9,0 +4,0 @@ gen: () => AsyncGenerator<T | Observable<T>, void, void>

+2
-2
src/index.ts

@@ -1,2 +0,2 @@

export * from "./asStream";
export * from "./fromAsyncIterator";
export { asStream } from "./asStream";
export { fromAsyncIterator } from "./fromAsyncIterator";