Skip to content

Commit b0cb174

Browse files
worstkillerakarnokd
authored andcommitted
refactor: improves Creating-Observables wiki doc (#6436)
1 parent b3d7f5f commit b0cb174

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

Diff for: docs/Creating-Observables.md

+8-8
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,8 @@ There exist overloads with 2 to 9 arguments for convenience, which objects (with
3737
```java
3838
Observable<Object> observable = Observable.just("1", "A", "3.2", "def");
3939

40-
observable.subscribe(item -> System.out.print(item), error -> error.printStackTrace,
41-
() -> System.out.println());
40+
observable.subscribe(item -> System.out.print(item), error -> error.printStackTrace(),
41+
() -> System.out.println());
4242
```
4343

4444
## From
@@ -80,7 +80,7 @@ for (int i = 0; i < array.length; i++) {
8080
array[i] = i;
8181
}
8282

83-
Observable<Integer> observable = Observable.fromIterable(array);
83+
Observable<Integer> observable = Observable.fromArray(array);
8484

8585
observable.subscribe(item -> System.out.println(item), error -> error.printStackTrace(),
8686
() -> System.out.println("Done"));
@@ -155,7 +155,7 @@ Given a pre-existing, already running or already completed `java.util.concurrent
155155
#### fromFuture example:
156156

157157
```java
158-
ScheduledExecutorService executor = Executors.newSingleThreadedScheduledExecutor();
158+
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
159159

160160
Future<String> future = executor.schedule(() -> "Hello world!", 1, TimeUnit.SECONDS);
161161

@@ -298,10 +298,10 @@ String greeting = "Hello World!";
298298

299299
Observable<Integer> indexes = Observable.range(0, greeting.length());
300300

301-
Observable<Char> characters = indexes
301+
Observable<Character> characters = indexes
302302
.map(index -> greeting.charAt(index));
303303

304-
characters.subscribe(character -> System.out.print(character), erro -> error.printStackTrace(),
304+
characters.subscribe(character -> System.out.print(character), error -> error.printStackTrace(),
305305
() -> System.out.println());
306306
```
307307

@@ -396,7 +396,7 @@ Observable<String> error = Observable.error(new IOException());
396396

397397
error.subscribe(
398398
v -> System.out.println("This should never be printed!"),
399-
error -> error.printStackTrace(),
399+
e -> e.printStackTrace(),
400400
() -> System.out.println("This neither!"));
401401
```
402402

@@ -423,4 +423,4 @@ for (int i = 0; i < 10; i++) {
423423
error -> error.printStackTrace(),
424424
() -> System.out.println("Done"));
425425
}
426-
```
426+
```

0 commit comments

Comments
 (0)