Skip to content
This repository has been archived by the owner on Feb 16, 2024. It is now read-only.

Rx.NET operators not implemented yet. #105

Open
neuecc opened this issue Dec 16, 2015 · 9 comments
Open

Rx.NET operators not implemented yet. #105

neuecc opened this issue Dec 16, 2015 · 9 comments

Comments

@neuecc
Copy link
Owner

neuecc commented Dec 16, 2015

Here is the list.

  • All(IObservable1 source, Func2 predicate)
  • And(IObservable1 left, IObservable1 right)
  • Any(IObservable`1 source)
  • Any(IObservable1 source, Func2 predicate)
  • Average(IObservable`1 source)
  • Average(IObservable1 source, Func2 selector)
  • Buffer(IObservable1 source, Func1 bufferClosingSelector)
  • Buffer(IObservable1 source, IObservable1 bufferOpenings, Func`2 bufferClosingSelector)
  • Case(Func1 selector, IDictionary2 sources)
  • Case(Func1 selector, IDictionary2 sources, IObservable`1 defaultSource)
  • Case(Func1 selector, IDictionary2 sources, IScheduler scheduler)
  • Catch(IObservable1 first, IObservable1 second)
  • Catch(IObservable`1[] sources)
  • Chunkify(IObservable`1 source)
  • Collect(IObservable1 source, Func1 getInitialCollector, Func3 merge, Func2 getNewCollector)
  • Collect(IObservable1 source, Func1 newCollector, Func`3 merge)
  • Contains(IObservable`1 source, TSource value)
  • Contains(IObservable1 source, TSource value, IEqualityComparer1 comparer)
  • Count(IObservable`1 source)
  • Count(IObservable1 source, Func2 predicate)
  • Delay(IObservable`1 source, DateTimeOffset dueTime)
  • Delay(IObservable`1 source, DateTimeOffset dueTime, IScheduler scheduler)
  • Delay(IObservable1 source, Func2 delayDurationSelector)
  • Delay(IObservable1 source, IObservable1 subscriptionDelay, Func`2 delayDurationSelector)
  • DoWhile(IObservable1 source, Func1 condition)
  • ElementAt(IObservable`1 source, Int32 index)
  • ElementAtOrDefault(IObservable`1 source, Int32 index)
  • Finally(IObservable`1 source, Action finallyAction)
  • Generate(TState initialState, Func2 condition, Func2 iterate, Func`2 resultSelector)
  • Generate(TState initialState, Func2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector)
  • Generate(TState initialState, Func2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector)
  • Generate(TState initialState, Func2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector, IScheduler scheduler)
  • Generate(TState initialState, Func2 condition, Func2 iterate, Func2 resultSelector, Func2 timeSelector, IScheduler scheduler)
  • Generate(TState initialState, Func2 condition, Func2 iterate, Func`2 resultSelector, IScheduler scheduler)
  • GroupBy(IObservable1 source, Func2 keySelector)
  • GroupBy(IObservable1 source, Func2 keySelector, Func`2 elementSelector)
  • GroupBy(IObservable1 source, Func2 keySelector, Func2 elementSelector, IEqualityComparer1 comparer)
  • GroupBy(IObservable1 source, Func2 keySelector, Func`2 elementSelector, Int32 capacity)
  • GroupBy(IObservable1 source, Func2 keySelector, Func2 elementSelector, Int32 capacity, IEqualityComparer1 comparer)
  • GroupBy(IObservable1 source, Func2 keySelector, IEqualityComparer`1 comparer)
  • GroupBy(IObservable1 source, Func2 keySelector, Int32 capacity)
  • GroupBy(IObservable1 source, Func2 keySelector, Int32 capacity, IEqualityComparer`1 comparer)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func`2 durationSelector)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func2 durationSelector, IEqualityComparer1 comparer)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func`2 durationSelector, Int32 capacity)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func2 durationSelector, Int32 capacity, IEqualityComparer1 comparer)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector, IEqualityComparer`1 comparer)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector, Int32 capacity)
  • GroupByUntil(IObservable1 source, Func2 keySelector, Func2 elementSelector, Func2 durationSelector, Int32 capacity, IEqualityComparer`1 comparer)
  • GroupJoin(IObservable1 left, IObservable1 right, Func2 leftDurationSelector, Func2 rightDurationSelector, Func`3 resultSelector)
  • If(Func1 condition, IObservable1 thenSource)
  • If(Func1 condition, IObservable1 thenSource, IObservable`1 elseSource)
  • If(Func1 condition, IObservable1 thenSource, IScheduler scheduler)
  • IsEmpty(IObservable`1 source)
  • Join(IObservable1 left, IObservable1 right, Func2 leftDurationSelector, Func2 rightDurationSelector, Func`3 resultSelector)
  • Latest(IObservable`1 source)
  • LongCount(IObservable`1 source)
  • LongCount(IObservable1 source, Func2 predicate)
  • Max(IObservable`1 source)
  • Max(IObservable1 source, Func2 selector)
  • Max(IObservable1 source, Func2 selector, IComparer`1 comparer)
  • Max(IObservable1 source, IComparer1 comparer)
  • MaxBy(IObservable1 source, Func2 keySelector)
  • MaxBy(IObservable1 source, Func2 keySelector, IComparer`1 comparer)
  • Min(IObservable`1 source)
  • Min(IObservable1 source, Func2 selector)
  • Min(IObservable1 source, Func2 selector, IComparer`1 comparer)
  • Min(IObservable1 source, IComparer1 comparer)
  • MinBy(IObservable1 source, Func2 keySelector)
  • MinBy(IObservable1 source, Func2 keySelector, IComparer`1 comparer)
  • MostRecent(IObservable`1 source, TSource initialValue)
  • Multicast(IObservable1 source, Func1 subjectSelector, Func`2 selector)
  • Next(IObservable`1 source)
  • OnErrorResumeNext(IEnumerable`1 sources)
  • OnErrorResumeNext(IObservable1 first, IObservable1 second)
  • OnErrorResumeNext(IObservable`1[] sources)
  • Publish(IObservable1 source, Func2 selector)
  • Publish(IObservable1 source, Func2 selector, TSource initialValue)
  • PublishLast(IObservable1 source, Func2 selector)
  • Replay(IObservable1 source, Func2 selector)
  • Replay(IObservable1 source, Func2 selector, Int32 bufferSize)
  • Replay(IObservable1 source, Func2 selector, Int32 bufferSize, IScheduler scheduler)
  • Replay(IObservable1 source, Func2 selector, Int32 bufferSize, TimeSpan window)
  • Replay(IObservable1 source, Func2 selector, Int32 bufferSize, TimeSpan window, IScheduler scheduler)
  • Replay(IObservable1 source, Func2 selector, IScheduler scheduler)
  • Replay(IObservable1 source, Func2 selector, TimeSpan window)
  • Replay(IObservable1 source, Func2 selector, TimeSpan window, IScheduler scheduler)
  • Sample(IObservable1 source, IObservable1 sampler)
  • SequenceEqual(IObservable1 first, IEnumerable1 second)
  • SequenceEqual(IObservable1 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(IEnumerable1 source, IObserver1 observer)
  • Subscribe(IEnumerable1 source, IObserver1 observer, IScheduler scheduler)
  • Sum(IObservable`1 source)
  • Sum(IObservable1 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(IObservable1 source, Func2 selector)
  • Throttle(IObservable1 source, Func2 throttleDurationSelector)
  • Timeout(IObservable1 source, DateTimeOffset dueTime, IObservable1 other)
  • Timeout(IObservable1 source, DateTimeOffset dueTime, IObservable1 other, IScheduler scheduler)
  • Timeout(IObservable1 source, Func2 timeoutDurationSelector)
  • Timeout(IObservable1 source, Func2 timeoutDurationSelector, IObservable`1 other)
  • Timeout(IObservable1 source, IObservable1 firstTimeout, Func`2 timeoutDurationSelector)
  • Timeout(IObservable1 source, IObservable1 firstTimeout, Func2 timeoutDurationSelector, IObservable1 other)
  • Timeout(IObservable1 source, TimeSpan dueTime, IObservable1 other)
  • Timeout(IObservable1 source, TimeSpan dueTime, IObservable1 other, IScheduler scheduler)
  • ToDictionary(IObservable1 source, Func2 keySelector)
  • ToDictionary(IObservable1 source, Func2 keySelector, Func`2 elementSelector)
  • ToDictionary(IObservable1 source, Func2 keySelector, Func2 elementSelector, IEqualityComparer1 comparer)
  • ToDictionary(IObservable1 source, Func2 keySelector, IEqualityComparer`1 comparer)
  • ToEnumerable(IObservable`1 source)
  • ToEvent(IObservable`1 source)
  • ToEventPattern(IObservable`1 source)
  • ToLookup(IObservable1 source, Func2 keySelector)
  • ToLookup(IObservable1 source, Func2 keySelector, Func`2 elementSelector)
  • ToLookup(IObservable1 source, Func2 keySelector, Func2 elementSelector, IEqualityComparer1 comparer)
  • ToLookup(IObservable1 source, Func2 keySelector, IEqualityComparer`1 comparer)
  • Using(Func1 resourceFactory, Func2 observableFactory)
  • Using(Func2 resourceFactoryAsync, Func3 observableFactoryAsync)
  • When(IEnumerable`1 plans)
  • When(Plan`1[] plans)
  • While(Func1 condition, IObservable1 source)
  • Window(IObservable1 source, Func1 windowClosingSelector)
  • Window(IObservable`1 source, Int32 count)
  • Window(IObservable`1 source, Int32 count, Int32 skip)
  • Window(IObservable1 source, IObservable1 windowBoundaries)
  • Window(IObservable1 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)
@astaror
Copy link

astaror commented May 20, 2016

Hello! Any estimates on Sum operator?

@neuecc
Copy link
Owner Author

neuecc commented May 24, 2016

Thank you.
Currently you can use Aggregate instead of Sum.

Window, Aggregation Operators, Generate is requested to me.
I'll implement it at first.

@franklin-ross
Copy link

franklin-ross commented Jul 8, 2016

-- Edited

I take it back, Switch() is already implemented.

@NikolayVoronkov
Copy link

Hello! How about Join operator?

@aalmada
Copy link

aalmada commented Oct 13, 2016

The items checked are the implemented or the not-yet-implemented ones?
I'm looking for Using(Func1 , Func2).

@jdnichollsc
Copy link

Hi guys, Is the list updated?

@mikey555
Copy link

mikey555 commented Jun 8, 2021

@neuecc are you still accepting pull requests? I'm thinking about implementing some of these operators.

@thsbrown
Copy link

Was also looking in to implementing OnErrorResumeNext as it stands right now I'm having to do some less then ideal work with Finally to get what I'm after.

@c84c
Copy link

c84c commented Oct 13, 2022

Hi guys!
Any chance to GroupByUntil?

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

9 participants