,System.DateTimeOffset)} ,System.DateTimeOffset,System.Reactive.Concurrency.IScheduler)} ,System.IObservable{--1})}
Qbservable.SkipUntil(IQbservable, DateTimeOffset) method¶
Defined in
Type: Qbservable
Namespace: System.Reactive.Linq
Assembly: System.Reactive.dll
Applies to
netstandard2.0
Overloads¶
- 1.
public static IQbservable<TSource> SkipUntil<TSource>(this IQbservable<TSource> source, DateTimeOffset startTime) - 2.
public static IQbservable<TSource> SkipUntil<TSource>(this IQbservable<TSource> source, DateTimeOffset startTime, IScheduler scheduler) - 3.
public static IQbservable<TSource> SkipUntil<TSource, TOther>(this IQbservable<TSource> source, IObservable<TOther> other)
1. Overload¶
public static IQbservable<TSource> SkipUntil<TSource>(this IQbservable<TSource> source, DateTimeOffset startTime)
Summary: Skips elements from the observable source sequence until the specified start time.
Type parameters
| Name | Description |
|---|---|
TSource | The type of the elements in the source sequence. |
Parameters
| Name | Type | Description |
|---|---|---|
source | [IQbservable | Source sequence to skip elements for. |
startTime | DateTimeOffset | Time to start taking elements from the source sequence. If this value is less than or equal to DateTimeOffset.UtcNow, no elements will be skipped. |
Returns: IQbservable
Remarks
Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the startTime.
Exceptions
| Type | Condition |
|---|---|
| System.ArgumentNullException | source is null. |
2. Overload¶
public static IQbservable<TSource> SkipUntil<TSource>(this IQbservable<TSource> source, DateTimeOffset startTime, IScheduler scheduler)
Summary: Skips elements from the observable source sequence until the specified start time, using the specified scheduler to run timers.
Type parameters
| Name | Description |
|---|---|
TSource | The type of the elements in the source sequence. |
Parameters
| Name | Type | Description |
|---|---|---|
source | [IQbservable | Source sequence to skip elements for. |
startTime | DateTimeOffset | Time to start taking elements from the source sequence. If this value is less than or equal to DateTimeOffset.UtcNow, no elements will be skipped. |
scheduler | [IScheduler](# | Scheduler to run the timer on. |
Returns: IQbservable
Remarks
Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the startTime.
Exceptions
| Type | Condition |
|---|---|
| System.ArgumentNullException | source or scheduler is null. |
3. Overload¶
public static IQbservable<TSource> SkipUntil<TSource, TOther>(this IQbservable<TSource> source, IObservable<TOther> other)
Summary:
Returns the elements from the source observable sequence only after the other observable sequence produces an element.
Starting from Rx.NET 4.0, this will subscribe to other before subscribing to source
so in case other emits an element right away, elements from source are not missed.
Type parameters
| Name | Description |
|---|---|
TSource | The type of the elements in the source sequence. |
TOther | The type of the elements in the other sequence that indicates the end of skip behavior. |
Parameters
| Name | Type | Description |
|---|---|---|
source | [IQbservable | Source sequence to propagate elements for. |
other | IObservable | Observable sequence that triggers propagation of elements of the source sequence. |
Returns: IQbservable
Exceptions
| Type | Condition |
|---|---|
| System.ArgumentNullException | source or other is null. |