Options
All
  • Public
  • Public/Protected
  • All
Menu

Class AsyncTaskPool<T>

同期化処理を非同期化するためのヘルパクラス。 array.forEach(value => process(value)); を以下のように書き換えて使う。 let pool = new AsyncTaskPool(); array.forEach(value => pool.add(()=> process(value)); pool.consume().then(()=> ...);

Type parameters

  • T

Hierarchy

  • AsyncTaskPool

Implements

Index

Properties

Methods

Properties

tasks

tasks: function[]

Type declaration

    • (): Promise<T>
    • Returns Promise<T>

Methods

add

  • add(value: function): void
  • add(task: function): void

consume

  • consume(): Promise<T[]>

handle

  • handle(value: any, statements: object): void
  • Parameters

    • value: any
    • statements: object
      • func: function
          • (): void
          • Returns void

      • next: function
          • (): void
          • Returns void

    Returns void

Generated using TypeDoc