Method run

packages/db-ivm/src/operators/output.ts:23–28

()

  }

  run(): void {
    for (const message of this.inputMessages()) {
      this.#fn(message)
      this.output.sendData(message)
    }
  }
}

/**