Light

reactivex / rxjava Goto Github PK

View Code? Open in Web Editor NEW

47.7K 2.2K 7.6K 138.22 MB

RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.

License: Apache License 2.0

Shell 0.02% Java 99.90% CSS 0.08%

java rxjava flow reactive-streams

rxjava's Issues

Observable: abstract or final

There is discussion about whether Observable should be a "final class" and only be usable via Observable.create(Func) or whether we should leave it as abstract.

Discuss and decide ...

Operator: GroupBy

http://msdn.microsoft.com/en-us/library/hh229301(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229261(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh212069(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229578(v=vs.103).aspx

Rx Schedulers

Implementation of Rx Schedulers (http://msdn.microsoft.com/en-us/library/hh242963(v=vs.103).aspx) ... probably to go into the rx.concurrency package (https://github.com/Netflix/RxJava/tree/master/rxjava-core/src/main/java/rx/concurrency).

Operator: Throttle

http://msdn.microsoft.com/en-us/library/hh229298(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229400(v=vs.103).aspx

Operator: Delay

http://msdn.microsoft.com/en-us/library/hh229677(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229810(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229250(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229280(v=vs.103).aspx

Operator: FromAsyncPattern

http://msdn.microsoft.com/en-us/library/hh211609(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh212031(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229082(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229412(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211747(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229591(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211886(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh244234(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229932(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229310(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh228969(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229364(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211735(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211688(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229052(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229172(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229266(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211975(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229724(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211982(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211893(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229544(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229074(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229398(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211651(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh244245(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211847(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229623(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229473(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229393(v=vs.103).aspx

Documentation: Introduction

Operator: Empty with scheduler

http://msdn.microsoft.com/en-us/library/hh229066(v=vs.103).aspx

Subject implementations

http://msdn.microsoft.com/en-us/library/hh242969(v=vs.103).aspx

This issue is intended to cover the implementation of various Subjects as part of Rx.Net intended for placement in rx.subjects.

Operator: ToIterable

We already from toObservable(Iterable)/from(Iterable) ... add the reverse blocking toIterable() similar to the non-blocking toList() which already exists.

ToEnumerable from C#: http://msdn.microsoft.com/en-us/library/hh212132(v=vs.103).aspx

Operator: Defer

http://msdn.microsoft.com/en-us/library/hh229160(v=vs.103).aspx

Operator: Buffer

http://msdn.microsoft.com/en-us/library/hh212130(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229308(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh228968(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229200(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211764(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211715(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229612(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229813(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229432(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229621(v=vs.103).aspx

Operator: Distinct

http://msdn.microsoft.com/en-us/library/hh229764(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211630(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh244310(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229050(v=vs.103).aspx

Operator: FromEvent

http://msdn.microsoft.com/en-us/library/hh244301(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211795(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229271(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229241(v=vs.103).aspx

Operator: IgnoreElements

http://msdn.microsoft.com/en-us/library/hh229242(v=vs.103).aspx

Documentation: Observables/Observer

Operator: ObserveOn

http://msdn.microsoft.com/en-us/library/hh211920(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229634(v=vs.103).aspx

Operator: Finally

http://msdn.microsoft.com/en-us/library/hh212133(v=vs.103).aspx

Operator: Amb

http://msdn.microsoft.com/en-us/library/hh229115(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229733(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211783(v=vs.103).aspx

Operator: ElementAt and ElementAtOrDefault

http://msdn.microsoft.com/en-us/library/hh229725(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229845(v=vs.103).aspx

Operator: Count

http://msdn.microsoft.com/en-us/library/hh229470(v=vs.103).aspx

Confirm Create Operator

The 'create' operator is already implemented but need to confirm all overloads and use cases are accounted for:

http://msdn.microsoft.com/en-us/library/hh229122(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229114(v=vs.103).aspx

Operator: Generate

http://msdn.microsoft.com/en-us/library/hh229642(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229270(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh212066(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh212014(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh244290(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211794(v=vs.103).aspx

Operator: All

http://msdn.microsoft.com/en-us/library/hh229537(v=vs.103).aspx

Operator: DefaultIfEmpty

http://msdn.microsoft.com/en-us/library/hh229332(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229624(v=vs.103).aspx

Operator: Publish and PublishLast

http://msdn.microsoft.com/en-us/library/hh229126(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211622(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229147(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229797(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh228989(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211697(v=vs.103).aspx

Operator: Catch

http://msdn.microsoft.com/en-us/library/hh229103(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211934(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211765(v=vs.103).aspx

How does this relate to this?

public static Observable onErrorResumeNext(final Observable that, final Func1<Exception, Observable> resumeFunction)

Should filter() be converted from Func<T, Boolean> to Pred<T>

Should we add a new special predicate object instead of using Func<T, Boolean>?

Operator: SubscribeOn

http://msdn.microsoft.com/en-us/library/hh228963(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229238(v=vs.103).aspx

Operator: GetEnumerator

http://msdn.microsoft.com/en-us/library/hh211873(v=vs.103).aspx

Operator: First and FirstOrDefault

http://msdn.microsoft.com/en-us/library/hh229177(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229739(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229320(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229759(v=vs.103).aspx

Operator: Contains

http://msdn.microsoft.com/en-us/library/hh228965(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229815(v=vs.103).aspx

Operator: CombineLatest

http://msdn.microsoft.com/en-us/library/hh211991(v=vs.103).aspx

Operator: Dematerialize

http://msdn.microsoft.com/en-us/library/hh229047(v=vs.103).aspx

Operator: GroupJoin

http://msdn.microsoft.com/en-us/library/hh244235(v=vs.103).aspx

Operator: Any

http://msdn.microsoft.com/en-us/library/hh229905(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211993(v=vs.103).aspx

Operator: Last

There is already a "last" operator but Rx includes another overload:

http://msdn.microsoft.com/en-us/library/hh229203(v=vs.103).aspx

Operator: DistinctUntilChanged

http://msdn.microsoft.com/en-us/library/hh229494(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229776(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229508(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229533(v=vs.103).aspx

Operator: And

http://msdn.microsoft.com/en-us/library/hh229153(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229905(v=vs.103).aspx

Operator: Interval

http://msdn.microsoft.com/en-us/library/hh229027(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh228911(v=vs.103).aspx

Operator: Aggregate

Add aggregate (or alias to reduce?)

http://msdn.microsoft.com/en-us/library/hh229154(v=vs.103).aspx

Operator: FromEventPattern

http://msdn.microsoft.com/en-us/library/hh211803(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229424(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229221(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229251(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229705(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229017(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211731(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229922(v=vs.103).aspx

Operator: Switch

http://msdn.microsoft.com/en-us/library/hh229197(v=vs.103).aspx

Operator: Concat

http://msdn.microsoft.com/en-us/library/hh212124(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229289(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211916(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh212146(v=vs.103).aspx

Operator: Cast

http://msdn.microsoft.com/en-us/library/hh211842(v=vs.103).aspx

Operator: ForEach

http://msdn.microsoft.com/en-us/library/hh211815(v=vs.103).aspx

Operator: Average

http://msdn.microsoft.com/en-us/library/hh211950(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229389(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211732(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211857(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211744(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh211770(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh212005(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229502(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229070(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229012(v=vs.103).aspx

Operator: Join

http://msdn.microsoft.com/en-us/library/hh229750(v=vs.103).aspx

Operator: GroupByUntil

http://msdn.microsoft.com/en-us/library/hh211932(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229872(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229433(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229392(v=vs.103).aspx

Operator: Do

http://msdn.microsoft.com/en-us/library/hh229804(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229307(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229659(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229539(v=vs.103).aspx
http://msdn.microsoft.com/en-us/library/hh229830(v=vs.103).aspx

Recommend Projects

React

A declarative, efficient, and flexible JavaScript library for building user interfaces.
Vue.js

🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
Typescript

TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
TensorFlow

An Open Source Machine Learning Framework for Everyone
Django

The Web framework for perfectionists with deadlines.
Laravel

A PHP framework for web artisans
D3

Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

javascript

JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
web

Some thing interesting about web. New door for the world.
server

A server is a program made to process requests and deliver data to clients.
Machine learning

Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Visualization

Some thing interesting about visualization, use data art
Game

Some thing interesting about game, make everyone happy.

Recommend Org

Facebook

We are working to build community through open source technology. NB: members must have two-factor auth.
Microsoft

Open source projects and samples from Microsoft.
Google

Google ❤️ Open Source for everyone.
Alibaba

Alibaba Open Source for everyone
D3

Data-Driven Documents codes.
Tencent

China tencent open source team.