@rimbu/stream
Advanced tools
Comparing version 0.13.0 to 0.13.1
import { Token } from '@rimbu/base'; | ||
import { ArrayNonEmpty, AsyncCollectFun, AsyncOptLazy, AsyncReducer, Eq, MaybePromise, TraverseState } from '@rimbu/common'; | ||
import type { AsyncFastIterator, AsyncStream, AsyncStreamSource } from '@rimbu/stream/async'; | ||
export declare const fixedDoneAsyncIteratorResult: Readonly<Promise<IteratorReturnResult<any> | IteratorYieldResult<any>>>; | ||
export declare const fixedDoneAsyncIteratorResult: Readonly<Promise<IteratorResult<any, any>>>; | ||
export declare function isAsyncFastIterator<T>(iterator: AsyncIterator<T>): iterator is AsyncFastIterator<T>; | ||
@@ -6,0 +6,0 @@ export declare const emptyAsyncFastIterator: AsyncFastIterator<any>; |
import type { MaybePromise } from '@rimbu/common'; | ||
import type { StreamSource } from '@rimbu/stream'; | ||
import type { AsyncStream, AsyncStreamable } from '@rimbu/stream/async'; | ||
export declare type AsyncStreamSource<T> = undefined | AsyncStreamSource.NonEmpty<T> | AsyncStream<T> | (() => MaybePromise<AsyncStreamSource<T>>) | AsyncStreamable<T> | StreamSource<T> | AsyncIterable<T>; | ||
export type AsyncStreamSource<T> = undefined | AsyncStreamSource.NonEmpty<T> | AsyncStream<T> | (() => MaybePromise<AsyncStreamSource<T>>) | AsyncStreamable<T> | StreamSource<T> | AsyncIterable<T>; | ||
export declare namespace AsyncStreamSource { | ||
type NonEmpty<T> = AsyncStream.NonEmpty<T> | AsyncStreamable.NonEmpty<T> | StreamSource.NonEmpty<T> | (() => MaybePromise<AsyncStreamSource.NonEmpty<T>>); | ||
} |
@@ -8,3 +8,3 @@ import { AsyncReducer, Eq } from '@rimbu/common'; | ||
*/ | ||
export declare type AsyncTransformer<T, R = T> = AsyncReducer<T, AsyncStreamSource<R>>; | ||
export type AsyncTransformer<T, R = T> = AsyncReducer<T, AsyncStreamSource<R>>; | ||
export declare namespace AsyncTransformer { | ||
@@ -11,0 +11,0 @@ /** |
@@ -6,3 +6,3 @@ import type { Stream, Streamable } from '@rimbu/stream'; | ||
*/ | ||
export declare type StreamSource<T> = undefined | Iterable<T> | Stream<T> | Streamable<T>; | ||
export type StreamSource<T> = undefined | Iterable<T> | Stream<T> | Streamable<T>; | ||
export declare namespace StreamSource { | ||
@@ -9,0 +9,0 @@ /** |
@@ -8,3 +8,3 @@ import { Eq, Reducer } from '@rimbu/common'; | ||
*/ | ||
export declare type Transformer<T, R = T> = Reducer<T, StreamSource<R>>; | ||
export type Transformer<T, R = T> = Reducer<T, StreamSource<R>>; | ||
export declare namespace Transformer { | ||
@@ -11,0 +11,0 @@ /** |
{ | ||
"name": "@rimbu/stream", | ||
"version": "0.13.0", | ||
"version": "0.13.1", | ||
"description": "Efficient structure representing a sequence of elements, with powerful operations for TypeScript", | ||
@@ -70,5 +70,5 @@ "keywords": [ | ||
"dependencies": { | ||
"@rimbu/base": "^0.11.0", | ||
"@rimbu/common": "^0.12.0", | ||
"tslib": "^2.4.0" | ||
"@rimbu/base": "^0.11.1", | ||
"@rimbu/common": "^0.12.1", | ||
"tslib": "^2.5.0" | ||
}, | ||
@@ -85,3 +85,3 @@ "publishConfig": { | ||
}, | ||
"gitHead": "442ffd299583458d458e9bbe3dd02c67828707f3" | ||
"gitHead": "f7a7662f81e9246b244cab22c14776617652833f" | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
1258109
24790
Updated@rimbu/base@^0.11.1
Updated@rimbu/common@^0.12.1
Updatedtslib@^2.5.0