Created
November 8, 2018 10:06
-
-
Save mcupak/d8f7986bcd0f7f7ba29333c4b089299a to your computer and use it in GitHub Desktop.
JShell transcript from the Exploring reactive programming in Java session at DevFest Toulouse 2018.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Thread t = new Thread(() -> System.out.println("hello devfest")) | |
t.start() | |
ExecutorService e = Executors.newSingleThreadExecutor() | |
Future<String> f = e.submit(() -> "hello devfest") | |
f | |
f.get() | |
ExecutorService e = ForkJoinPool.commonPool() | |
Future<String> f = e.submit(() -> "hello devfest") | |
f.get() | |
CompletableFuture<String> cf = new CompletableFuture<String>() | |
cf.complete("done") | |
cf.get() | |
CompletableFuture<String> cf = new CompletableFuture<String>() | |
cf.get() | |
cf.completeExceptionally(new IllegalStateException()) | |
cf.get() | |
CompletableFuture.supplyAsync(() -> "hello").thenApplyAsync(x -> x + " devfest").thenAccept(System.out::println) | |
CompletableFuture.supplyAsync(() -> "hello").thenCombineAsync(CompletableFuture.supplyAsync(() -> " devfest"), (x, y) -> x + y).thenAccept(System.out::println) | |
CompletableFuture.supplyAsync(() -> "hello").thenCombineAsync(CompletableFuture.supplyAsync(() -> " devfest"), (x, y) -> x + y).exceptionally(t -> "We have an error: " + t.getMessage()).thenAccept(System.out::println) | |
CompletableFuture.supplyAsync(() -> "hello").thenCombineAsync(CompletableFuture.failedFuture(new IllegalStateException()), (x, y) -> x + y).exceptionally(t -> "We have an error: " + t.getMessage()).thenAccept(System.out::println) | |
CompletableFuture<String> cf = new CompletableFuture<String>() | |
cf.completeOnTimeout("timed out", 5, TimeUnit.SECONDS) | |
cf.get() | |
CompletableFuture<String> cf = new CompletableFuture<String>() | |
cf.orTimeout(5, TimeUnit.SECONDS) | |
cf.get() | |
CompletableFuture<String> cf = new CompletableFuture<String>() | |
CompletableFuture<String> copy = cf.copy() | |
cf.complete("done") | |
cf | |
copy | |
copy.get() | |
CompletableFuture<String> cf = new CompletableFuture<String>() | |
CompletableFuture<String> copy = cf.copy() | |
copy.complete("done") | |
copy | |
cf | |
class SimpleSubscriber implements Subscriber<String> { | |
public void onSubscribe(Subscription sub) {} | |
public void onNext(String item) {} | |
public void onError(Throwable t) {} | |
public void onComplete() {} | |
} | |
/ed SimpleSubscriber | |
/ed e1 | |
SimpleSubscriber sub = new SimpleSubscriber() | |
SubmissionPublisher<String> pub = new SubmissionPublisher<String>() | |
pub.subscribe(sub) | |
pub.getSubscribers() | |
pub.submit("hello devfest") | |
pub.submit("hello devfest") | |
pub.submit("hello devfest") | |
pub.submit("hello devfest") | |
pub.submit("hello devfest") | |
pub.close() | |
pub.submit("hello devfest") | |
HttpHandler handler = he -> { | |
String body = "hello devfest"; | |
he.sendResponseHeaders(200, body.length()); | |
try (OutputStream os = he.getResponseBody()) { | |
os.write(body.getBytes()); | |
} | |
} | |
HttpServer hs = HttpServer.create(new InetSocketAddress(8000), 0) | |
hs.createContext("/hello", handler) | |
hs.start() | |
HttpClient hc = HttpClient.newHttpClient() | |
hc.version() | |
HttpRequest request = HttpRequest.newBuilder().uri(URI.create("http://localhost:8000/hello")).GET().build() | |
HttpResponse<String> response = hc.send(request, BodyHandlers.ofString()) | |
response.statusCode() | |
response.body() | |
CompletableFuture<HttpResponse<String>> response = hc.sendAsync(request, BodyHandlers.ofString()) | |
response.get().body() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment