import { type Subscriber } from '../types/index.mjs';

export const toSubscriber = <A,>(
  onNext: (v: A) => void,
  onComplete?: () => void,
): Subscriber<A> =>
  ({
    onNext,
    onComplete: onComplete ?? (() => {}),
  }) as const;