import { Observable } from "rxjs"; /** @internal */ export declare class SubscriptionScheduler { private _scheduler; constructor(concurrency: number); /** * Schedules `source` for subscription in the current scheduler. * * The actual scheduling is performed when the returned observable is subscribed to. To cancel, remove all subscribers * from the returned observable. * * @param source Input observable for which to schedule a subscription. * @returns Hot observable which starts emitting `source` values after subscription. */ scheduleSubscription(source: Observable): Observable; } //# sourceMappingURL=SubscriptionScheduler.d.ts.map