// 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

*/