src/emitter/get-iterable-from-emitter.ts from Codibre/fluent-iterable

src/emitter/get-iterable-from-emitter.ts

Summary

Maintainability

0 mins

Test Coverage

100%

Issues
Source
Stats

Issues

Coverage

import { FluentEmitOptions } from '../types/base';
import { EventEmitter } from 'events';

export function getIterableFromEmitter<T = any>(
  emitter: EventEmitter,
  options: FluentEmitOptions | undefined,
): AsyncIterable<T> {
  return require('for-emit-of')(emitter, { ...options, keepAlive: 1000 });
}