// /
import { Entry, Pair, KoconutIterable } from '../../../module';
import { EventEmitter } from 'events';
export declare class Flow
extends EventEmitter
implements Iterable>
{
private static newDatumInsertedEvent;
private static dataScanningCompletedEvent;
private mPentDataSize;
private mChainedFlow;
private mInnerDataMap;
[Symbol.iterator](): Iterator>;
constructor(
srcSequence?: Iterable<
[number, DataType] | Entry | Pair
> | null,
);
static of(
...srcSequence: (
| [number, DataType]
| Entry
| Pair
)[]
): Flow;
static from(
srcSequence?: Iterable<
[number, DataType] | Entry | Pair
> | null,
): Flow;
static ofSimple(...srcSequence: DataType[]): Flow;
static fromSimple(
srcSequence?: Iterable | null,
): Flow;
private sort;
get dataArray(): Array;
get dataEntries(): Array>;
private setDatum;
private onNewDatumInserted;
}
export declare class KoconutFlow extends KoconutIterable<
Entry,
Entry,
Flow,
Flow
> {
private mIsChained;
validate(data: Flow | null): Promise;
constructor(
srcSequence?: Iterable<
[number, DataType] | Entry | Pair
> | null,
);
static from(
srcSequence?: Iterable<
[number, DataType] | Entry | Pair
> | null,
): KoconutFlow;
static of(
...srcSequence: (
| [number, DataType]
| Entry
| Pair
)[]
): KoconutFlow;
static fromSimple(
srcSequence?: Iterable | null,
): KoconutFlow;
static ofSimple(...srcSequence: DataType[]): KoconutFlow;
mapFlow(
transform: (element: DataType) => ResultDataType | Promise,
thisArg?: any,
): KoconutFlow;
yield(): Promise>;
}