Function finalize

finalize(effect: () => unknown): <T>(source: AsyncIterable<T>) => Stream<T>
Registers a cleanup callback that runs once when the stage closes, if the stage was started.

The callback runs after upstream stages and in-flight operations in the stage have finished. Nested finalize callbacks run from inner stages outward.
Parameters
- effect: () => unknown
Returns <T>(source: AsyncIterable<T>) => Stream<T>
finalize<T>(effect: () => unknown): Operator<T, T>
Registers a cleanup callback that runs once when the stage closes, if the stage was started.

The callback runs after upstream stages and in-flight operations in the stage have finished. Nested finalize callbacks run from inner stages outward.
Type Parameters
- T
Parameters
- effect: () => unknown
Returns Operator<T, T>