-
Notifications
You must be signed in to change notification settings - Fork 7.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
More operators/overloads #653
Comments
Reviewed by @headinthebox and I for things that should not be added and used |
What is a use case when this would ever be needed? @headinthebox mentioned that it's not really used in Rx.Net so likely not worth us adding. |
Okay, no worries. I won't start working on the remaining ones for at least a week. |
Closing this and ignoring |
Rx.NET 2.2.2
Aggregate (PR Operations Aggregate, Average and Sum with selector #657)aggregate(seed, accumulator, resultselector)
average(Func1<T, Number> valueselector)
Buffer(Observable<U> bufferBoundaries)
Create asyncCreate(Func1<Observer<R>, Task>)
Create(Func1<Observer<R>, Task<Action>>)
Create(Func1<Observer<R>, Task<IDisposable>>)
Create(Func2<Observer<R>, CancellationToken, Task>)
Create(Func2<Observer<R>, CancellationToken, Task<Action>>)
Create(Func2<Observer<R>, CancellationToken, Task<IDisposable>>)
Delay(Func1<T, Observable<TDelay>>)
Delay(Func0<Observable<D1>> subscriptionDelay, Func1<T, Observable<D2>> itemDelay)
Empty (PR Empty, Error and Never overloads with type witness #654)Empty(T witness)
Empty(Scheduler, T witness)
Never (PR Empty, Error and Never overloads with type witness #654)Never(T witness)
publish(Func1<Observable<TSource>, Observable<TResult>> sel)
publish(TSource initialValue)
publish(Func1<Observable<TSource>, Observable<TResult>> sel, TSource initialValue)
publishLast(Func1<Observable<TSource>, Observable<TResult>> sel)
SelectMany(Func1<T, Observable<U>> collection, Func2<T, U, R> resultSel)
SelectMany(Func1<T, Observable<R>> onNext, Func1<Exception, Observable<R>> onError, Func0<Observable<R>> onCompleted)
SelectMany(Func1<T, IEnumerable<R>>)
SelectMany(Func2<T, IEnumerable<U>>, Func2<T, U, R>)
----------------------------------SelectMany(Func2<T, Integer, Observable<R>>)
SelectMany(Func1<T, Task<R>>)
SelectMany(Func2<T, Integer, Task<R>>)
SelectMany(Func2<T, CancellationToken, Task<R>>)
SelectMany(Func3<T, Integer, CancellationTokenk, Task<R>>)
SelectMany(Func1<T, Integer, Observable<U>> collection, Func4<T, Integer, U, Integr, R> resultSel)
SelectMany(Func1<T, Task<U>>, Func2<T, U, R>)
SelectMany(Func2<T, Integer, Task<U>>, Func2<T, Integer, U, R>)
SelectMany(Func2<T, CT, Task<U>>, Func2<T, U, R>)
SelectMany(Func3<T, Integer, CT, Task<U>>, Func2<T, Integer, U, R>)
SelectMany(Func2<T, Integer, Observable<R>> onNext, Func1<Exception, Observable<R>> onError, Func0<Observable<R>> onCompleted)
SelectMany(Func2<T, Integer, IEnumerable<R>>)
SelectMany(Func3<T, Integer, IEnumerable<U>>, Func4<T, Integer, U, Integer, R>)
Skip(Timespan)
Skip(Timespan, Scheduler)
SkipLast(Timespan)
SkipLast(Timespan, Scheduler)
sum(Func1<T, Number> valueselector)
Take(Timespan)
Take(Timespan, Scheduler)
TakeLast(Timespan)
TakeLast(Timespan, Scheduler)
TakeLast(Timespan, Scheduler duration, Scheduler drain)
Throttle(Func1<T, Observable<Void>>)
Timeout(Func1<T, Observable<Void>>)
Timeout(Func1<T, Observable<Void>>, Observable<T> other)
Timeout(Func0<Observable<Void>>, Func1<T, Observable<Void>>)
Timeout(Func0<Observable<Void>>, Func1<T, Observable<Void>>, Observable<T> other)
Throw (error) (PR Empty, Error and Never overloads with type witness #654)error(Throwable t, T witness)
error(Throwable t, Scheduler, T witness)
Using asyncUsing(Func1<CancellationToken, Task<TResource>>, Func2<TResource, CancellationToken, Task<Observable<T>>>)
WhereWhere(Func2<T, Integer, Boolean>)
Window(Observable<U> windowBoundaries)
(already have with FuncN)Zip(IEnumerable<Observable<S>> sources, Func1<IList<S>, R> selector)
Zip(Iterable<U> other, Func2<T, U, R> result)
(instance method)Zip(Observable<U> other, Func2<T, U, R> result)
(instance method)Potential Java specific operators/overloads:
just(Func0<R> factory)
return the value of the factory for the subscriber.lock(Lock lock)
orsynchronize(Lock lock)
to support j.u.c.Locks for synchronization.Using with java.io.Closeableusing(Func0<C>, Func1<C, Observable<T>>)
usingFuture(Func1<BooleanSubscription, Future<C>>, Func2<C, BooleanSubscription, Future<Observable<T>>>)
The text was updated successfully, but these errors were encountered: