/** * A hot, multicast {@link AsyncIterable}: every concurrent iterator receives every value * {@link publish}ed from the moment it starts iterating, mirroring the semantics of C#'s * `IObservable` (via `Observable.FromEvent`) that {@link IEventSequence.appendOperations} is * based on. Values published while nobody is iterating are simply dropped — there is no replay * buffer, matching a hot observable with no subscribers. */ export declare class AppendOperationsBroadcaster implements AsyncIterable { private readonly _subscribers; /** Whether at least one consumer is currently iterating this broadcaster. */ get hasSubscribers(): boolean; /** Publishes a value to every current subscriber. */ publish(value: T): void; [Symbol.asyncIterator](): AsyncIterator; } //# sourceMappingURL=AppendOperationsBroadcaster.d.ts.map