We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb9ecb9 commit ce98a5bCopy full SHA for ce98a5b
src/main/java/com/github/davidmoten/rx/Checked.java
@@ -9,6 +9,31 @@
9
/**
10
* Utility functions that are useful for brevity when using checked exceptions
11
* in lambdas with RxJava.
12
+ *
13
+ * <p>
14
+ * Instead of
15
+ * </p>
16
17
+ * <pre>
18
+ * OutputStream os = ...;
19
+ * Observable<String> source = ...;
20
+ * source.doOnNext(s -> {
21
+ * try {
22
+ * os.write(s.getBytes());
23
+ * } catch (IOException e) {
24
+ * throw new RuntimeException(e);
25
+ * }
26
+ * })
27
+ * .subscribe();
28
+ * </pre>
29
30
31
+ * you can write:
32
33
34
35
+ * source.doOnNext(Checked.a1(s -> os.write(s.getBytes()))).subscribe();
36
37
*/
38
public final class Checked {
39
0 commit comments