Stream overview

Added in v1.0.0

---

Table of contents

• utils
  • asyncPauseResume

---

utils

asyncPauseResume

Signature

export declare const asyncPauseResume: <R, E, A>(
  register: (emit: {
    readonly single: (item: A) => void
    readonly fail: (error: E) => void
    readonly end: () => void
  }) => {
    readonly onInterrupt: Effect.Effect<void, never, R>
    readonly onPause: Effect.Effect<void>
    readonly onResume: Effect.Effect<void>
  },
  bufferSize?: number
) => Stream.Stream<A, E, R>

Added in v1.0.0