43 lines
1.1 KiB
Java
43 lines
1.1 KiB
Java
|
// concurrent/ThrowsChecked.java
|
||
|
|
// (c)2017 MindView LLC: see Copyright.txt
|
||
|
|
// We make no guarantees that this code is fit for any purpose.
|
||
|
|
// Visit http://OnJava8.com for more book information.
|
||
|
|
import java.util.stream.*;
|
||
|
|
import java.util.concurrent.*;
|
||
|
|
|
||
|
|
public class ThrowsChecked {
|
||
|
|
class Checked extends Exception {}
|
||
|
|
static ThrowsChecked nochecked(ThrowsChecked tc) {
|
||
|
|
return tc;
|
||
|
|
}
|
||
|
|
static ThrowsChecked
|
||
|
|
withchecked(ThrowsChecked tc) throws Checked {
|
||
|
|
return tc;
|
||
|
|
}
|
||
|
|
static void testStream() {
|
||
|
|
Stream.of(new ThrowsChecked())
|
||
|
|
.map(ThrowsChecked::nochecked)
|
||
|
|
// .map(ThrowsChecked::withchecked); // [1]
|
||
|
|
.map(tc -> {
|
||
|
|
try {
|
||
|
|
return withchecked(tc);
|
||
|
|
} catch(Checked e) {
|
||
|
|
throw new RuntimeException(e);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
static void testCompletableFuture() {
|
||
|
|
CompletableFuture
|
||
|
|
.completedFuture(new ThrowsChecked())
|
||
|
|
.thenApply(ThrowsChecked::nochecked)
|
||
|
|
// .thenApply(ThrowsChecked::withchecked); // [2]
|
||
|
|
.thenApply(tc -> {
|
||
|
|
try {
|
||
|
|
return withchecked(tc);
|
||
|
|
} catch(Checked e) {
|
||
|
|
throw new RuntimeException(e);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|