fp-ts-iterators
Advanced tools
Comparing version
@@ -36,4 +36,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.tap = exports.uniq = exports.lefts = exports.rights = exports.compact = exports.filterMapTask = exports.filterMapTaskWithIndex = exports.filterMap = exports.filterMapWithIndex = exports.filterTask = exports.filterTaskWithIndex = exports.filter = exports.filterWithIndex = exports.MonadIO = exports.FromTask = exports.FromIO = exports.Monad = exports.Unfoldable = exports.Chain = exports.flatten = exports.flatMapTask = exports.flatMapTaskWithIndex = exports.flatMapIterable = exports.flatMap = exports.Applicative = exports.apSecond = exports.apFirst = exports.Apply = exports.apTask = exports.ap = exports.flap = exports.asUnit = exports.as = exports.FunctorWithIndex = exports.Functor = exports.map = exports.mapWithIndex = exports.Pointed = exports.of = exports.fromTask = exports.fromIO = exports.fromLazyArg = exports.fromIterable = exports.unfoldTask = exports.unfold = exports.makeByTask = exports.makeByTaskWithIndex = exports.makeBy = exports.makeByWithIndex = exports.URI = void 0; | ||
exports.foldMapSeq = exports.foldMapPar = exports.foldMapWithIndexPar = exports.apS = exports.let = exports.bindTo = exports.bind = exports.Do = exports.tapIO = exports.tapTask = void 0; | ||
exports.uniq = exports.lefts = exports.rights = exports.compact = exports.filterMapTask = exports.filterMapTaskWithIndex = exports.filterMap = exports.filterMapWithIndex = exports.filterTask = exports.filterTaskWithIndex = exports.filter = exports.filterWithIndex = exports.MonadIO = exports.FromTask = exports.FromIO = exports.Monad = exports.Unfoldable = exports.Chain = exports.flattenIterable = exports.flatten = exports.flatMapTask = exports.flatMapTaskWithIndex = exports.flatMapIterable = exports.flatMap = exports.Applicative = exports.apSecond = exports.apFirst = exports.Apply = exports.apTask = exports.ap = exports.flap = exports.asUnit = exports.as = exports.FunctorWithIndex = exports.Functor = exports.map = exports.mapWithIndex = exports.Pointed = exports.of = exports.fromTask = exports.fromIO = exports.fromLazyArg = exports.fromIterable = exports.unfoldTask = exports.unfold = exports.makeByTask = exports.makeByTaskWithIndex = exports.makeBy = exports.makeByWithIndex = exports.URI = void 0; | ||
exports.foldMapSeq = exports.foldMapPar = exports.foldMapWithIndexPar = exports.apS = exports.let = exports.bindTo = exports.bind = exports.Do = exports.tapIO = exports.tapTask = exports.tap = void 0; | ||
exports.fromAsyncGenerator = fromAsyncGenerator; | ||
@@ -422,2 +422,7 @@ exports.transform = transform; | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
exports.flattenIterable = (0, exports.flatMapIterable)(function_1.identity); | ||
/** | ||
* @category instances | ||
@@ -424,0 +429,0 @@ * @since 1.0.0 |
@@ -36,4 +36,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Chain = exports.Applicative = exports.apSecond = exports.apFirst = exports.Apply = exports.flap = exports.asUnit = exports.as = exports.Functor = exports.Pointed = exports.flatMapTaskOption = exports.flatMapTaskEither = exports.flatMapTask = exports.flatMapOption = exports.flatMapEither = exports.flatMap = exports.apW = exports.ap = exports.mapError = exports.mapBoth = exports.map = exports.swap = exports.fromNullable = exports.toUnion = exports.getOrElseW = exports.matchEW = exports.matchW = exports.match = exports.fromAsyncIterableOption = exports.fromIOEither = exports.fromEither = exports.fromAsyncIterable = exports.fromIterable = exports.fromTaskOption = exports.fromTaskEitherK = exports.fromTaskEither = exports.fromTask = exports.fromIO = exports.leftIO = exports.rightIO = exports.leftAsyncIterable = exports.rightAsyncIterable = exports.of = exports.leftTask = exports.rightTask = exports.leftIterable = exports.rightIterable = exports.right = exports.left = exports.URI = void 0; | ||
exports.apS = exports.let = exports.bindTo = exports.bind = exports.Do = exports.flatten = exports.flattenW = exports.tapErrorTaskEither = exports.tapErrorTask = exports.tapErrorIO = exports.tapError = exports.tapEither = exports.tapIO = exports.tapTaskEither = exports.tapTask = exports.tap = exports.filterMapTaskEither = exports.filterMapTaskEitherWithIndex = exports.filterMapTask = exports.filterMapTaskWithIndex = exports.filterMap = exports.filterMapWithIndex = exports.filterTaskEither = exports.filterTaskEitherWithIndex = exports.filterTask = exports.filterTaskWithIndex = exports.filter = exports.filterWithIndex = exports.MonadTask = exports.MonadIO = exports.MonadThrow = exports.throwError = exports.Monad = exports.fromPredicate = exports.fromOptionK = exports.fromOption = exports.fromEitherK = exports.FromEither = exports.fromTaskK = exports.FromTask = exports.fromIOK = exports.FromIO = void 0; | ||
exports.Applicative = exports.apSecond = exports.apFirst = exports.Apply = exports.flap = exports.asUnit = exports.as = exports.Functor = exports.Pointed = exports.flatMapTaskOption = exports.flatMapTaskEither = exports.flatMapTask = exports.flatMapOption = exports.flatMapEither = exports.flatMapIterable = exports.flatMap = exports.apW = exports.ap = exports.mapError = exports.mapBoth = exports.map = exports.swap = exports.fromNullable = exports.toUnion = exports.getOrElseW = exports.matchEW = exports.matchW = exports.match = exports.fromAsyncIterableOption = exports.fromIOEither = exports.fromEither = exports.fromAsyncIterable = exports.fromIterable = exports.fromTaskOption = exports.fromTaskEitherK = exports.fromTaskEither = exports.fromTask = exports.fromIO = exports.leftIO = exports.rightIO = exports.leftAsyncIterable = exports.rightAsyncIterable = exports.of = exports.leftTask = exports.rightTask = exports.leftIterable = exports.rightIterable = exports.right = exports.left = exports.URI = void 0; | ||
exports.apS = exports.let = exports.bindTo = exports.bind = exports.Do = exports.flattenIterable = exports.flatten = exports.flattenW = exports.tapErrorTaskEither = exports.tapErrorTask = exports.tapErrorIO = exports.tapError = exports.tapEither = exports.tapIO = exports.tapTaskEither = exports.tapTask = exports.tap = exports.filterMapTaskEither = exports.filterMapTaskEitherWithIndex = exports.filterMapTask = exports.filterMapTaskWithIndex = exports.filterMap = exports.filterMapWithIndex = exports.filterTaskEither = exports.filterTaskEitherWithIndex = exports.filterTask = exports.filterTaskWithIndex = exports.filter = exports.filterWithIndex = exports.MonadTask = exports.MonadIO = exports.MonadThrow = exports.throwError = exports.Monad = exports.fromPredicate = exports.fromOptionK = exports.fromOption = exports.fromEitherK = exports.FromEither = exports.fromTaskK = exports.FromTask = exports.fromIOK = exports.FromIO = exports.Chain = void 0; | ||
exports.matchE = matchE; | ||
@@ -331,2 +331,7 @@ exports.getOrElse = getOrElse; | ||
*/ | ||
exports.flatMapIterable = (0, internal_1.dual)(2, (0, internalEither_1.flatMap)(I.Monad)); | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
const flatMapEither = (f) => (fa) => ({ | ||
@@ -783,2 +788,7 @@ async *[Symbol.asyncIterator]() { | ||
exports.flatten = exports.flattenW; | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
exports.flattenIterable = (0, exports.flatMapIterable)(function_1.identity); | ||
// ------------------------------------------------------------------------------------- | ||
@@ -785,0 +795,0 @@ // do notation |
@@ -359,2 +359,7 @@ import { apFirst as apFirst_, apS as apS_, apSecond as apSecond_, } from "fp-ts/lib/Apply"; | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
export const flattenIterable = /*#__PURE__*/ flatMapIterable(identity); | ||
/** | ||
* @category instances | ||
@@ -361,0 +366,0 @@ * @since 1.0.0 |
@@ -276,2 +276,7 @@ import { apFirst as apFirst_, apS as apS_, apSecond as apSecond_, } from "fp-ts/lib/Apply"; | ||
*/ | ||
export const flatMapIterable = dual(2, flatMap_(I.Monad)); | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
export const flatMapEither = (f) => (fa) => ({ | ||
@@ -708,2 +713,7 @@ async *[Symbol.asyncIterator]() { | ||
export const flatten = flattenW; | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
export const flattenIterable = flatMapIterable(identity); | ||
// ------------------------------------------------------------------------------------- | ||
@@ -710,0 +720,0 @@ // do notation |
@@ -218,2 +218,7 @@ /** | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
export declare const flattenIterable: <A>(mma: AsyncIterable<Iterable<A>>) => AsyncIterable<A>; | ||
/** | ||
* @category instances | ||
@@ -220,0 +225,0 @@ * @since 1.0.0 |
@@ -286,2 +286,10 @@ /** | ||
*/ | ||
export declare const flatMapIterable: { | ||
<A, B>(f: (a: A) => Iterable<B>): <E>(ma: AsyncIterableEither<E, A>) => AsyncIterableEither<E, B>; | ||
<E, A, B>(ma: AsyncIterableEither<E, A>, f: (a: A) => Iterable<B>): AsyncIterableEither<E, B>; | ||
}; | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
export declare const flatMapEither: <E1, E2, A, B>(f: (a: A) => E.Either<E2, B>) => (fa: AsyncIterableEither<E1, A>) => AsyncIterableEither<E1 | E2, B>; | ||
@@ -622,2 +630,7 @@ /** | ||
/** | ||
* @category sequencing | ||
* @since 1.0.0 | ||
*/ | ||
export declare const flattenIterable: <E, A>(mma: AsyncIterableEither<E, Iterable<A>>) => AsyncIterableEither<E, A>; | ||
/** | ||
* @category do notation | ||
@@ -624,0 +637,0 @@ * @since 1.0.0 |
{ | ||
"name": "fp-ts-iterators", | ||
"version": "0.5.0", | ||
"version": "0.6.0", | ||
"description": "Functional Iterable and AsyncIterable", | ||
@@ -5,0 +5,0 @@ "main": "build/cjs/index.js", |
229990
0.61%8320
0.58%