Skip to content

@epikodelabs/streamix


@epikodelabs/streamix / share

Function: share()

share<T>(): Operator<T, T>

Defined in: projects/libraries/streamix/src/lib/operators/share.ts:16

Shares a single subscription to the source stream between multiple consumers.

This operator multicasts the upstream iterator through an internal subject so that every subsequent consumer receives the same values without re-running the source. The subject does not replay values for late subscribers; they receive only values emitted after they subscribe.

Type Parameters

T

T = any

Value type in the shared stream.

Returns

Operator<T, T>

An operator that can be inserted into a pipeline to share the source.

Released under the MIT License.