| 123456789101112131415161718192021222324252627 |
- import { Connectable, ObservableInput, SubjectLike } from '../types';
- export interface ConnectableConfig<T> {
- /**
- * A factory function used to create the Subject through which the source
- * is multicast. By default this creates a {@link Subject}.
- */
- connector: () => SubjectLike<T>;
- /**
- * If true, the resulting observable will reset internal state upon disconnection
- * and return to a "cold" state. This allows the resulting observable to be
- * reconnected.
- * If false, upon disconnection, the connecting subject will remain the
- * connecting subject, meaning the resulting observable will not go "cold" again,
- * and subsequent repeats or resubscriptions will resubscribe to that same subject.
- */
- resetOnDisconnect?: boolean;
- }
- /**
- * Creates an observable that multicasts once `connect()` is called on it.
- *
- * @param source The observable source to make connectable.
- * @param config The configuration object for `connectable`.
- * @returns A "connectable" observable, that has a `connect()` method, that you must call to
- * connect the source to all consumers through the subject provided as the connector.
- */
- export declare function connectable<T>(source: ObservableInput<T>, config?: ConnectableConfig<T>): Connectable<T>;
- //# sourceMappingURL=connectable.d.ts.map
|
