src/index.ts
import {
AsyncPredicate,
Page,
Pager,
FluentIterable,
FluentAsyncIterable,
FluentGroup,
OrderAssurable,
} from './types';
import {
Predicate,
Reducer,
AsyncReducer,
Comparer,
Action,
AsyncAction,
Group,
FluentEmitter,
head,
tail,
} from './types/base';
import fluent from './fluent';
import { fluentEmit } from './fluent-async';
import { fluentAsync } from './fluent-async-func';
import depaginate from './depaginator';
import { interval } from './interval';
import { mergeIterators, mergeIterables } from './async-base/merging';
import {
assureOrder as o,
assureOrderDescending as od,
getMinMaxStepper,
getStatsStepper,
} from './utils';
import { AsyncMapper, Mapper } from 'augmentative-iterable';
export * from './extend-async';
export * from './extend';
export * from './transform-obj-values';
export {
o,
od,
OrderAssurable,
FluentIterable,
FluentAsyncIterable,
Predicate,
AsyncPredicate,
Mapper,
AsyncMapper,
Reducer,
AsyncReducer,
Comparer,
Action,
AsyncAction,
Group,
FluentGroup,
Page,
Pager,
fluent,
fluentAsync,
fluentEmit,
FluentEmitter,
depaginate,
interval,
mergeIterables,
mergeIterators,
head,
tail,
getMinMaxStepper,
getStatsStepper,
};
export * from './utils';
export * from './is-async-iterable';
export * from './is-iterable';
export * from './f';
export * from './fluent-object';
export * from './is-fluent-async-iterable';
export * from './is-fluent-iterable';
export * from './is-any-iterable';
export * from './is-any-fluent-iterable';
export * from './fluent-for';
export * from './fluent-for-async';
async function test() {
fluentAsync([{ a: 1 }, { a: 1 }, { a: 1 }])
.flatJoin('a')
.toArray();
}
void test();