Class StreamSequenceProcessor

iterable

[asyncIterator]

• "[asyncIterator]"(): AsyncIterator<
      Iterable<[Path, Value, number, number], any, any>,
      any,
      any,
  >

  Returns AsyncIterator<Iterable<[Path, Value, number, number], any, any>, any, any>

drop

• drop(n: number): this

  Parameters

  • n: number

  Returns this

every

• every(
      predicate: (
          item: [Path, Value, number, number],
          index: number,
      ) => boolean,
  ): Promise<boolean>

  Parameters

  • predicate: (item: [Path, Value, number, number], index: number) => boolean

  Returns Promise<boolean>

filter

• filter(
      func: (item: [Path, Value, number, number], index: number) => boolean,
  ): this

  Parameters

  • func: (item: [Path, Value, number, number], index: number) => boolean

  Returns this

find

• find(
      predicate: (
          item: [Path, Value, number, number],
          index: number,
      ) => boolean,
  ): Promise<undefined | [Path, Value, number, number]>

  Parameters

  • predicate: (item: [Path, Value, number, number], index: number) => boolean

  Returns Promise<undefined | [Path, Value, number, number]>

flatMap

• flatMap(
      func: (
          item: [Path, Value, number, number],
          index: number,
      ) =>
          | [Path, Value, number, number]
          | Iterable<[Path, Value, number, number], any, any>,
  ): this

  Parameters

  • func: (
        item: [Path, Value, number, number],
        index: number,
    ) =>
        | [Path, Value, number, number]
        | Iterable<[Path, Value, number, number], any, any>

  Returns this

forEach

• forEach(
      func: (item: [Path, Value, number, number], index: number) => void,
  ): Promise<void>

  Parameters

  • func: (item: [Path, Value, number, number], index: number) => void

  Returns Promise<void>

map

• map(
      func: (
          item: [Path, Value, number, number],
          index: number,
      ) => [Path, Value, number, number],
  ): this

  Parameters

  • func: (
        item: [Path, Value, number, number],
        index: number,
    ) => [Path, Value, number, number]

  Returns this

reduce

• reduce<U>(
      func: (acc: U, item: [Path, Value, number, number], index: number) => U,
      initialValue?: U,
  ): Promise<U>

  Type Parameters

  • U

  Parameters

  • func: (acc: U, item: [Path, Value, number, number], index: number) => U
  • OptionalinitialValue: U

  Returns Promise<U>

some

• some(
      predicate: (
          item: [Path, Value, number, number],
          index: number,
      ) => boolean,
  ): Promise<boolean>

  Parameters

  • predicate: (item: [Path, Value, number, number], index: number) => boolean

  Returns Promise<boolean>

take

• take(n: number): this

  Parameters

  • n: number

  Returns this

toArray

• toArray(): Promise<[Path, Value, number, number][]>

  Returns Promise<[Path, Value, number, number][]>

toAsyncIterable

• toAsyncIterable(): AsyncIterable<[Path, Value, number, number]>

  Returns AsyncIterable<[Path, Value, number, number]>

toBatchIterable

• toBatchIterable(): GenericBatchIterable<any>

  Returns a general purpose batchiterable which is less strict in typing but lacks methods that requires the correct types to be enforced

  Returns GenericBatchIterable<any>