Function collectEvents

packages/db/tests/effect.test.ts:61–67

Collect events from an effect into an array

(
  events: Array<DeltaEvent<T, any>>,
)

/** Collect events from an effect into an array */
function collectEvents<T extends object = Record<string, unknown>>(
  events: Array<DeltaEvent<T, any>>,
) {
  return (event: DeltaEvent<T, any>) => {
    events.push(event)
  }
}

/** Collect all events from a batch callback into an array */
function collectBatchEvents<T extends object = Record<string, unknown>>(