41 lines
1.0 KiB
Java
41 lines
1.0 KiB
Java
|
// concurrent/StreamExceptions.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.concurrent.*;
|
||
|
|
import java.util.stream.*;
|
||
|
|
|
||
|
|
public class StreamExceptions {
|
||
|
|
static Stream<Breakable>
|
||
|
|
test(String id, int failcount) {
|
||
|
|
return
|
||
|
|
Stream.of(new Breakable(id, failcount))
|
||
|
|
.map(Breakable::work)
|
||
|
|
.map(Breakable::work)
|
||
|
|
.map(Breakable::work)
|
||
|
|
.map(Breakable::work);
|
||
|
|
}
|
||
|
|
public static void main(String[] args) {
|
||
|
|
// No operations are even applied ...
|
||
|
|
test("A", 1);
|
||
|
|
test("B", 2);
|
||
|
|
Stream<Breakable> c = test("C", 3);
|
||
|
|
test("D", 4);
|
||
|
|
test("E", 5);
|
||
|
|
// ... until there's a terminal operation:
|
||
|
|
System.out.println("Entering try");
|
||
|
|
try {
|
||
|
|
c.forEach(System.out::println); // [1]
|
||
|
|
} catch(Exception e) {
|
||
|
|
System.out.println(e.getMessage());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/* Output:
|
||
|
|
Entering try
|
||
|
|
Breakable_C [2]
|
||
|
|
Breakable_C [1]
|
||
|
|
Throwing Exception for C
|
||
|
|
Breakable_C failed
|
||
|
|
*/
|