/// <reference types="node" />
import { IObserver } from './types';
declare const subscribe: ({ next, error, complete }: IObserver) => (...streams: NodeJS.ReadableStream[]) => () => void;
export default subscribe;