Skip to content

,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

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence to skip elements for.
startTimeDateTimeOffsetTime 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 -- An observable sequence with the elements skipped until the specified start time.

Remarks

Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the startTime.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource 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

NameDescription
TSourceThe type of the elements in the source sequence.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence to skip elements for.
startTimeDateTimeOffsetTime 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 -- An observable sequence with the elements skipped until the specified start time.

Remarks

Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the startTime.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource 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

NameDescription
TSourceThe type of the elements in the source sequence.
TOtherThe type of the elements in the other sequence that indicates the end of skip behavior.

Parameters

NameTypeDescription
source[IQbservable](#Source sequence to propagate elements for.
otherIObservableObservable sequence that triggers propagation of elements of the source sequence.

Returns: IQbservable -- An observable sequence containing the elements of the source sequence starting from the point the other sequence triggered propagation.

Exceptions

TypeCondition
System.ArgumentNullExceptionsource or other is null.