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

}

});

}

}