Signal class¶
Defined in
Namespace: ReactiveUI.Primitives.Reactive.Signals
Assembly: ReactiveUI.Primitives.Reactive.dll
Full name: ReactiveUI.Primitives.Reactive.Signals.Signal
Modifiers: public static
Summary¶
Factory surface for the multicast subject signals, for callers who prefer a factory over the concrete constructors.
Applies to
net10.0, net10.0-android36.0, net10.0-ios26.0, net10.0-macos26.0, net10.0-tvos26.0, net10.0-maccatalyst26.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-desktop1.0, net9.0-browserwasm1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net481, net471, net462
Methods¶
| Name | Summary |
|---|---|
| static Create | Create anonymous Signals. Observer has exception durability. This is recommended for make operator and event, generating a HotSignals. |
| static CreateWithState | Create anonymous Signals. Observer has exception durability. This is recommended for make operator and event, generating a HotSignals. |
| static CreateSafe | Create anonymous Signals. Safe means auto detach when error raised in onNext pipeline. This is recommended for making a ColdSignals. |
| static Lazy | Lazily creates the source sequence for each subscription. |
| static Defer | Creates a signal whose source is produced asynchronously for each subscription. |
| static Emit | Emit a single value on the specified scheduler. |
| static EmitRxVoid | Same as Signals.Emit(RxVoid.Default); but no allocate memory. |
| static Sequence | Creates a finite integer signal from start for count values. |
| static Loop | Creates a signal that repeats a value forever. |
| static Unfold | Unfolds state into a finite signal. |
| static Iterate | Generates a finite signal from state. Alias of [Unfold](# |
| static Use | Creates a signal whose subscription lifetime owns a resource. |
| static FromEventPattern | Converts an event into a signal of event pattern values. |
| static FromEnumerable | Creates a signal from an enumerable sequence. |
| static FromTask | Creates a signal from a task instance. |
| static FromAsync | Creates a signal by invoking an asynchronous factory at subscription time. |
| static Expire | Fails the sequence if it does not terminate before the timeout. |
| static Start | Runs a function on the supplied scheduler and emits its result. |
| static FromAsyncEnumerable | Creates a signal from an async enumerable sequence and cancels enumeration when disposed. |
| static After | Emits a single zero tick after the due time. |
| static Every | Emits monotonically increasing ticks at the specified period. |
| static Chain | Concatenates the supplied signals. |
| static Blend | Merges the supplied signals. |
| static Race | Races the supplied signals and mirrors the first one to produce a value or terminal signal. |
| static Pair | Mirrors the first supplied signal to produce a value or terminal signal. |
| static SyncLatest | Combines the latest values from two signals. |
| static ForkJoin | Waits for both signals to complete and emits one result from their last values. |
| static Fail | Empty Signals. Returns only onError on specified scheduler. |
| static RunAsync | Executes the RunAsync operation. |
| static ToTask | Awaits source completion and returns the last value produced by the source. |
| static None | Empty Signals. Returns only OnCompleted on specified scheduler. |
| static Recover | Continues an observable sequence that is terminated by an exception with the next observable sequence. |
| static Pulse | Emits monotonically increasing ticks at the specified period. |
| static If | Returns the source selected by the condition for each subscription. |
| static Case | Returns the source selected by the dictionary key for each subscription. |
| static Return | Returns an observable sequence that contains a single value. |
| static Repeat | Returns an observable sequence that repeats a value indefinitely. |
| static Empty | Returns an empty observable sequence. |
| static Never | Returns a non-terminating observable sequence. |
| static Throw | Returns an observable sequence that terminates with an error. |
| static Range | Returns an observable sequence that emits a range of integral values. |
| static Generate | Generates a finite observable sequence from state. |
| static Timer | Returns an observable sequence that emits a single tick after the due time. |
| static Interval | Returns an observable sequence that emits monotonically increasing ticks at the specified interval. |
| static Timeout | Fails the sequence if it does not terminate before the timeout. |
| static Concat | Concatenates the supplied observable sources. |
| static Merge | Merges the supplied observable sources. |
| static OnErrorResumeNext | Continues with the second sequence after the first sequence completes or errors. |
| static Using | Creates a signal whose subscription lifetime owns a resource. |
| static Switch | Switches to the most recent inner observable sequence. |
| static PairLatest | Combines latest values from two signals using latest-fusion semantics. |
| static Silent | Non-Terminating Signals. It's no returns, never finish. |
| static Scheduled | Creates a signal that dispatches its notifications on scheduler. |
| static Delayable | Creates a signal that buffers notifications while delayed and emits a de-duplicated batch when [Flush](# is called. |