@@ -17,7 +17,7 @@ This page shows methods that create reactive sources, such as `Observable`s.
17
17
18
18
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Completable `
19
19
20
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/just.html ] ( http://reactivex.io/documentation/operators/just.html )
20
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/just.html ] ( http://reactivex.io/documentation/operators/just.html )
21
21
22
22
Constructs a reactive type by taking a pre-existing object and emitting that specific object to the downstream consumer upon subscription.
23
23
@@ -46,7 +46,7 @@ Constructs a sequence from a pre-existing source or generator type.
46
46
47
47
* Note: These static methods use the postfix naming convention (i.e., the argument type is repeated in the method name) to avoid overload resolution ambiguities.*
48
48
49
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/from.html ] ( http://reactivex.io/documentation/operators/from.html )
49
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/from.html ] ( http://reactivex.io/documentation/operators/from.html )
50
50
51
51
### fromIterable
52
52
@@ -203,7 +203,7 @@ observable.subscribe(
203
203
204
204
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Completable `
205
205
206
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/create.html ] ( http://reactivex.io/documentation/operators/create.html )
206
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/create.html ] ( http://reactivex.io/documentation/operators/create.html )
207
207
208
208
Construct a ** safe** reactive type instance which when subscribed to by a consumer, runs an user-provided function and provides a type-specific ` Emitter ` for this function to generate the signal(s) the designated business logic requires. This method allows bridging the non-reactive, usually listener/callback-style world, with the reactive world.
209
209
@@ -239,7 +239,7 @@ executor.shutdown();
239
239
240
240
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Completable `
241
241
242
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/defer.html ] ( http://reactivex.io/documentation/operators/defer.html )
242
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/defer.html ] ( http://reactivex.io/documentation/operators/defer.html )
243
243
244
244
Calls an user-provided ` java.util.concurrent.Callable ` when a consumer subscribes to the reactive type so that the ` Callable ` can generate the actual reactive instance to relay signals from towards the consumer. ` defer ` allows:
245
245
@@ -266,7 +266,7 @@ observable.subscribe(time -> System.out.println(time));
266
266
267
267
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Completable `
268
268
269
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/range.html ] ( http://reactivex.io/documentation/operators/range.html )
269
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/range.html ] ( http://reactivex.io/documentation/operators/range.html )
270
270
271
271
Generates a sequence of values to each individual consumer. The ` range() ` method generates ` Integer ` s, the ` rangeLong() ` generates ` Long ` s.
272
272
@@ -287,7 +287,7 @@ characters.subscribe(character -> System.out.print(character), erro -> error.pri
287
287
288
288
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Completable `
289
289
290
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/interval.html ] ( http://reactivex.io/documentation/operators/interval.html )
290
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/interval.html ] ( http://reactivex.io/documentation/operators/interval.html )
291
291
292
292
Periodically generates an infinite, ever increasing numbers (of type ` Long ` ). The ` intervalRange ` variant generates a limited amount of such numbers.
293
293
@@ -309,7 +309,7 @@ clock.subscribe(time -> {
309
309
310
310
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Completable `
311
311
312
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/timer.html ] ( http://reactivex.io/documentation/operators/timer.html )
312
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/timer.html ] ( http://reactivex.io/documentation/operators/timer.html )
313
313
314
314
After the specified time, this reactive source signals a single ` 0L ` (then completes for ` Flowable ` and ` Observable ` ).
315
315
@@ -325,7 +325,7 @@ eggTimer.blockingSubscribe(v -> System.out.println("Egg is ready!"));
325
325
326
326
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_off.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Completable `
327
327
328
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/empty-never-throw.html ] ( http://reactivex.io/documentation/operators/empty-never-throw.html )
328
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/empty-never-throw.html ] ( http://reactivex.io/documentation/operators/empty-never-throw.html )
329
329
330
330
This type of source signals completion immediately upon subscription.
331
331
@@ -344,7 +344,7 @@ empty.subscribe(
344
344
345
345
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Completable `
346
346
347
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/empty-never-throw.html ] ( http://reactivex.io/documentation/operators/empty-never-throw.html )
347
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/empty-never-throw.html ] ( http://reactivex.io/documentation/operators/empty-never-throw.html )
348
348
349
349
This type of source does not signal any ` onNext ` , ` onSuccess ` , ` onError ` or ` onComplete ` . This type of reactive source is useful in testing or "disabling" certain sources in combinator operators.
350
350
@@ -363,7 +363,7 @@ never.subscribe(
363
363
364
364
** Available in:** ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Flowable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Observable ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Maybe ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Single ` , ![ image] ( https://raw.github.com/wiki/ReactiveX/RxJava/images/checkmark_on.png ) ` Completable `
365
365
366
- ** ReactiveX doumentation :** [ http://reactivex.io/documentation/operators/empty-never-throw.html ] ( http://reactivex.io/documentation/operators/empty-never-throw.html )
366
+ ** ReactiveX documentation :** [ http://reactivex.io/documentation/operators/empty-never-throw.html ] ( http://reactivex.io/documentation/operators/empty-never-throw.html )
367
367
368
368
Signal an error, either pre-existing or generated via a ` java.util.concurrent.Callable ` , to the consumer.
369
369
0 commit comments