FilesExpand file tree

 2.x

/

package-info.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

52 lines (51 loc) · 2.38 KB

 2.x

/

package-info.java

Copy path

Top

File metadata and controls

• Code
• Blame

52 lines (51 loc) · 2.38 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

/**

* Copyright (c) 2016-present, RxJava Contributors.

*

* Licensed under the Apache License, Version 2.0 (the "License");

* you may not use this file except in compliance with the License.

* You may obtain a copy of the License at

*

* http://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS,

* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

* See the License for the specific language governing permissions and

* limitations under the License.

*/

/**

* Base reactive classes: Flowable, Observable, Single and Completable; base reactive consumers;

* other common base interfaces.

*

* <p>A library that enables subscribing to and composing asynchronous events and

* callbacks.</p>

* <p>The Flowable/Subscriber, Observable/Observer, Single/SingleObserver and

* Completable/CompletableObserver interfaces and associated operators (in

* the {@code io.reactivex.internal.operators} package) are inspired by the

* Reactive Rx library in Microsoft .NET but designed and implemented on

* the more advanced Reactive-Streams ( http://www.reactivestreams.org ) principles.</p>

* <p>

* More information can be found at <a

* href="http://msdn.microsoft.com/en-us/data/gg577609">http://msdn.microsoft.com/en-us/data/gg577609</a>.

* </p>

*

*

* <p>Compared with the Microsoft implementation:

* <ul>

* <li>Observable == IObservable (base type)</li>

* <li>Observer == IObserver (event consumer)</li>

* <li>Disposable == IDisposable (resource/cancellation management)</li>

* <li>Observable == Observable (factory methods)</li>

* <li>Flowable == IAsyncEnumerable (backpressure)</li>

* <li>Subscriber == IAsyncEnumerator</li>

* </ul>

* The Single and Completable reactive base types have no equivalent in Rx.NET as of 3.x.

* </p>

* <p>Services which intend on exposing data asynchronously and wish

* to allow reactive processing and composition can implement the

* {@link io.reactivex.Flowable}, {@link io.reactivex.Observable}, {@link io.reactivex.Single}

* or {@link io.reactivex.Completable} class which then allow consumers to subscribe to them

* and receive events.</p>

* <p>Usage examples can be found on the {@link io.reactivex.Flowable}/{@link io.reactivex.Observable} and {@link org.reactivestreams.Subscriber} classes.</p>

*/

package io.reactivex;