Skip to content

})} },System.Reactive.Concurrency.IScheduler)}

ReactiveExtensions.ForEach(IObservable>) method

Defined in

Type: ReactiveExtensions Namespace: ReactiveUI.Extensions Assembly: ReactiveUI.Extensions.dll

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.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, net462, net481

Overloads

  • 1. public static IObservable<T> ForEach<T>(this IObservable<IEnumerable<T>> source)
  • 2. public static IObservable<T> ForEach<T>(this IObservable<IEnumerable<T>> source, IScheduler? scheduler)

1. Overload

public static IObservable<T> ForEach<T>(this IObservable<IEnumerable<T>> source)

View source

Summary: Flattens a sequence of enumerables into individual values.

Type parameters

NameDescription
TElement type.

Parameters

NameTypeDescription
sourceIObservable>Source of enumerables.

Returns: IObservable -- A flattened observable.

2. Overload

public static IObservable<T> ForEach<T>(this IObservable<IEnumerable<T>> source, IScheduler? scheduler)

View source

Summary: Flattens a sequence of enumerables into individual values.

Type parameters

NameDescription
TElement type.

Parameters

NameTypeDescription
sourceIObservable>Source of enumerables.
scheduler[IScheduler?](#Scheduler (optional).

Returns: IObservable -- A flattened observable.