Method enqueueSinkWrite

src/gateway/bindingRuntime.ts:289–297

(action: () => Promise<void>)

  }

  private enqueueSinkWrite(action: () => Promise<void>): void {
    this.sinkWriteQueue = this.sinkWriteQueue.then(async () => {
      try {
        await action();
      } catch (error) {
        log.warn('sink write event error', error);
      }
    });
  }

  private async flushSinkWriteQueue(): Promise<void> {
    await this.sinkWriteQueue;