Rx.NET operators not implemented yet.
Author: neueccCreated Dec 16, 2015Updated Oct 13, 2022
Here is the list.
- All(IObservable
1 source, Func2 predicate) - And(IObservable
1 left, IObservable1 right) - Any(IObservable`1 source)
- Any(IObservable
1 source, Func2 predicate) - Average(IObservable`1 source)
- Average(IObservable
1 source, Func2 selector) - Buffer(IObservable
1 source, Func1 bufferClosingSelector) - Buffer(IObservable
1 source, IObservable1 bufferOpenings, Func`2 bufferClosingSelector) - Case(Func
1 selector, IDictionary2 sources) - Case(Func
1 selector, IDictionary2 sources, IObservable`1 defaultSource) - Case(Func
1 selector, IDictionary2 sources, IScheduler scheduler) - Catch(IObservable
1 first, IObservable1 second) - Catch(IObservable`1[] sources)
- Chunkify(IObservable`1 source)
- Collect(IObservable
1 source, Func1 getInitialCollector, Func3 merge, Func2 getNewCollector) - Collect(IObservable
1 source, Func1 newCollector, Func`3 merge) - Contains(IObservable`1 source, TSource value)
- Contains(IObservable
1 source, TSource value, IEqualityComparer1 comparer) - Count(IObservable`1 source)
- Count(IObservable
1 source, Func2 predicate) - Delay(IObservable`1 source, DateTimeOffset dueTime)
- Delay(IObservable`1 source, DateTimeOffset dueTime, IScheduler scheduler)
- Delay(IObservable
1 source, Func2 delayDurationSelector) - Delay(IObservable
1 source, IObservable1 subscriptionDelay, Func`2 delayDurationSelector) - DoWhile(IObservable
1 source, Func1 condition) - ElementAt(IObservable`1 source, Int32 index)
- ElementAtOrDefault(IObservable`1 source, Int32 index)
- Finally(IObservable`1 source, Action finallyAction)
- Generate(TState initialState, Func
2 condition, Func2 iterate, Func`2 resultSelector) - Generate(TState initialState, Func
2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector) - Generate(TState initialState, Func
2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector) - Generate(TState initialState, Func
2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector, IScheduler scheduler) - Generate(TState initialState, Func
2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector, IScheduler scheduler) - Generate(TState initialState, Func
2 condition, Func2 iterate, Func`2 resultSelector, IScheduler scheduler) - GroupBy(IObservable
1 source, Func2 keySelector) - GroupBy(IObservable
1 source, Func2 keySelector, Func`2 elementSelector) - GroupBy(IObservable
1 source, Func2 keySelector, Func2 elementSelector, IEqualityComparer1 comparer) - GroupBy(IObservable
1 source, Func2 keySelector, Func`2 elementSelector, Int32 capacity) - GroupBy(IObservable
1 source, Func2 keySelector, Func2 elementSelector, Int32 capacity, IEqualityComparer1 comparer) - GroupBy(IObservable
1 source, Func2 keySelector, IEqualityComparer`1 comparer) - GroupBy(IObservable
1 source, Func2 keySelector, Int32 capacity) - GroupBy(IObservable
1 source, Func2 keySelector, Int32 capacity, IEqualityComparer`1 comparer) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func`2 durationSelector) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func2 durationSelector, IEqualityComparer1 comparer) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func`2 durationSelector, Int32 capacity) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func2 durationSelector, Int32 capacity, IEqualityComparer1 comparer) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector, IEqualityComparer`1 comparer) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector, Int32 capacity) - GroupByUntil(IObservable
1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector, Int32 capacity, IEqualityComparer`1 comparer) - GroupJoin(IObservable
1 left, IObservable1 right, Func2 leftDurationSelector, Func2 rightDurationSelector, Func`3 resultSelector) - If(Func
1 condition, IObservable1 thenSource) - If(Func
1 condition, IObservable1 thenSource, IObservable`1 elseSource) - If(Func
1 condition, IObservable1 thenSource, IScheduler scheduler) - IsEmpty(IObservable`1 source)
- Join(IObservable
1 left, IObservable1 right, Func2 leftDurationSelector, Func2 rightDurationSelector, Func`3 resultSelector) - Latest(IObservable`1 source)
- LongCount(IObservable`1 source)
- LongCount(IObservable
1 source, Func2 predicate) - Max(IObservable`1 source)
- Max(IObservable
1 source, Func2 selector) - Max(IObservable
1 source, Func2 selector, IComparer`1 comparer) - Max(IObservable
1 source, IComparer1 comparer) - MaxBy(IObservable
1 source, Func2 keySelector) - MaxBy(IObservable
1 source, Func2 keySelector, IComparer`1 comparer) - Min(IObservable`1 source)
- Min(IObservable
1 source, Func2 selector) - Min(IObservable
1 source, Func2 selector, IComparer`1 comparer) - Min(IObservable
1 source, IComparer1 comparer) - MinBy(IObservable
1 source, Func2 keySelector) - MinBy(IObservable
1 source, Func2 keySelector, IComparer`1 comparer) - MostRecent(IObservable`1 source, TSource initialValue)
- Multicast(IObservable
1 source, Func1 subjectSelector, Func`2 selector) - Next(IObservable`1 source)
- OnErrorResumeNext(IEnumerable`1 sources)
- OnErrorResumeNext(IObservable
1 first, IObservable1 second) - OnErrorResumeNext(IObservable`1[] sources)
- Publish(IObservable
1 source, Func2 selector) - Publish(IObservable
1 source, Func2 selector, TSource initialValue) - PublishLast(IObservable
1 source, Func2 selector) - Replay(IObservable
1 source, Func2 selector) - Replay(IObservable
1 source, Func2 selector, Int32 bufferSize) - Replay(IObservable
1 source, Func2 selector, Int32 bufferSize, IScheduler scheduler) - Replay(IObservable
1 source, Func2 selector, Int32 bufferSize, TimeSpan window) - Replay(IObservable
1 source, Func2 selector, Int32 bufferSize, TimeSpan window, IScheduler scheduler) - Replay(IObservable
1 source, Func2 selector, IScheduler scheduler) - Replay(IObservable
1 source, Func2 selector, TimeSpan window) - Replay(IObservable
1 source, Func2 selector, TimeSpan window, IScheduler scheduler) - Sample(IObservable
1 source, IObservable1 sampler) - SequenceEqual(IObservable
1 first, IEnumerable1 second) - SequenceEqual(IObservable
1 first, IEnumerable1 second, IEqualityComparer`1 comparer) - SkipLast(IObservable`1 source, Int32 count)
- SkipLast(IObservable`1 source, TimeSpan duration)
- SkipLast(IObservable`1 source, TimeSpan duration, IScheduler scheduler)
- SkipUntil(IObservable`1 source, DateTimeOffset startTime)
- SkipUntil(IObservable`1 source, DateTimeOffset startTime, IScheduler scheduler)
- Subscribe(IEnumerable
1 source, IObserver1 observer) - Subscribe(IEnumerable
1 source, IObserver1 observer, IScheduler scheduler) - Sum(IObservable`1 source)
- Sum(IObservable
1 source, Func2 selector) - TakeLast(IObservable`1 source, Int32 count)
- TakeLast(IObservable`1 source, Int32 count, IScheduler scheduler)
- TakeLast(IObservable`1 source, TimeSpan duration)
- TakeLast(IObservable`1 source, TimeSpan duration, IScheduler scheduler)
- TakeLast(IObservable`1 source, TimeSpan duration, IScheduler timerScheduler, IScheduler loopScheduler)
- TakeLastBuffer(IObservable`1 source, Int32 count)
- TakeLastBuffer(IObservable`1 source, TimeSpan duration)
- TakeLastBuffer(IObservable`1 source, TimeSpan duration, IScheduler scheduler)
- TakeUntil(IObservable`1 source, DateTimeOffset endTime)
- TakeUntil(IObservable`1 source, DateTimeOffset endTime, IScheduler scheduler)
- Then(IObservable
1 source, Func2 selector) - Throttle(IObservable
1 source, Func2 throttleDurationSelector) - Timeout(IObservable
1 source, DateTimeOffset dueTime, IObservable1 other) - Timeout(IObservable
1 source, DateTimeOffset dueTime, IObservable1 other, IScheduler scheduler) - Timeout(IObservable
1 source, Func2 timeoutDurationSelector) - Timeout(IObservable
1 source, Func2 timeoutDurationSelector, IObservable`1 other) - Timeout(IObservable
1 source, IObservable1 firstTimeout, Func`2 timeoutDurationSelector) - Timeout(IObservable
1 source, IObservable1 firstTimeout, Func2 timeoutDurationSelector, IObservable1 other) - Timeout(IObservable
1 source, TimeSpan dueTime, IObservable1 other) - Timeout(IObservable
1 source, TimeSpan dueTime, IObservable1 other, IScheduler scheduler) - ToDictionary(IObservable
1 source, Func2 keySelector) - ToDictionary(IObservable
1 source, Func2 keySelector, Func`2 elementSelector) - ToDictionary(IObservable
1 source, Func2 keySelector, Func2 elementSelector, IEqualityComparer1 comparer) - ToDictionary(IObservable
1 source, Func2 keySelector, IEqualityComparer`1 comparer) - ToEnumerable(IObservable`1 source)
- ToEvent(IObservable`1 source)
- ToEventPattern(IObservable`1 source)
- ToLookup(IObservable
1 source, Func2 keySelector) - ToLookup(IObservable
1 source, Func2 keySelector, Func`2 elementSelector) - ToLookup(IObservable
1 source, Func2 keySelector, Func2 elementSelector, IEqualityComparer1 comparer) - ToLookup(IObservable
1 source, Func2 keySelector, IEqualityComparer`1 comparer) - Using(Func
1 resourceFactory, Func2 observableFactory) - Using(Func
2 resourceFactoryAsync, Func3 observableFactoryAsync) - When(IEnumerable`1 plans)
- When(Plan`1[] plans)
- While(Func
1 condition, IObservable1 source) - Window(IObservable
1 source, Func1 windowClosingSelector) - Window(IObservable`1 source, Int32 count)
- Window(IObservable`1 source, Int32 count, Int32 skip)
- Window(IObservable
1 source, IObservable1 windowBoundaries) - Window(IObservable
1 source, IObservable1 windowOpenings, Func`2 windowClosingSelector) - Window(IObservable`1 source, TimeSpan timeSpan)
- Window(IObservable`1 source, TimeSpan timeSpan, Int32 count)
- Window(IObservable`1 source, TimeSpan timeSpan, Int32 count, IScheduler scheduler)
- Window(IObservable`1 source, TimeSpan timeSpan, IScheduler scheduler)
- Window(IObservable`1 source, TimeSpan timeSpan, TimeSpan timeShift)
- Window(IObservable`1 source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)
Source: neuecc/UniRx