<A>(options?: { readonly replay?: number | undefined }): PubSub.Atomic<A>Creates an unbounded atomic PubSub implementation with optional replay buffer.
When to use
Use to create the low-level storage layer for a custom PubSub whose active
subscribers may retain an unbounded number of pending messages.
Gotchas
Messages published while subscribers are active can be retained without a capacity limit until those subscribers take them or unsubscribe.
export const const makeAtomicUnbounded: <A>(options?: {
readonly replay?: number | undefined
}) => PubSub.Atomic<A>
Creates an unbounded atomic PubSub implementation with optional replay buffer.
When to use
Use to create the low-level storage layer for a custom PubSub whose active
subscribers may retain an unbounded number of pending messages.
Gotchas
Messages published while subscribers are active can be retained without a
capacity limit until those subscribers take them or unsubscribe.
makeAtomicUnbounded = <function (type parameter) A in <A>(options?: {
readonly replay?: number | undefined;
}): PubSub.Atomic<A>
options: | {
readonly replay?: number | undefined
}
| undefined
replay?: number | undefinedreplay?: number | undefined
}): PubSub.interface PubSub<in out A>.Atomic<in out A>Low-level atomic PubSub interface that handles the core message storage and retrieval.
Atomic<function (type parameter) A in <A>(options?: {
readonly replay?: number | undefined;
}): PubSub.Atomic<A>
constructor UnboundedPubSub<A>(replayBuffer: ReplayBuffer<A> | undefined): UnboundedPubSub<A>UnboundedPubSub(options: | {
readonly replay?: number | undefined
}
| undefined
replay?: number | undefinedreplay ? new constructor ReplayBuffer<A>(capacity: number): ReplayBuffer<A>ReplayBuffer(options: {
readonly replay?: number | undefined
}
replay?: numberreplay) : var undefinedundefined)