import type { Operator } from './index';
/**
 * Apply stream of values to the raceFunction, emitting output values in order of completion.  By default, it allows
 * up to 128 concurrent values to be processed.
 * @param raceFunction
 * @param concurrent
 */
export default function <Input, Output>(raceFunction: (value: Input) => Promise<Output>, concurrent?: number): Operator<Input, Output>;