SqlStream

declare function asyncPauseResume<A, E = never, R = never>(register: (emit: {
  readonly array: (chunk: readonly Array<A>) => void;
  readonly chunk: (chunk: Chunk<A>) => void;
  readonly end: () => void;
  readonly fail: (error: E) => void;
  readonly single: (item: A) => void;
}) => {
  readonly onInterrupt: Effect<void, never, R>;
  readonly onPause: Effect<void>;
  readonly onResume: Effect<void>;
}, bufferSize: number): Stream<A, E, R>