Created
November 20, 2018 12:59
-
-
Save mcupak/85f0fe2fd0d586645076b04ed8034910 to your computer and use it in GitHub Desktop.
JShell transcript from my Reactive programming in Java session at VoxxedDays Thessaloniki 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 thessaloniki")) | |
t.start() | |
ExecutorService e = Executors.newSingleThreadExecutor() | |
Future<String> f = e.submit(() -> "hello thessaloniki") | |
f | |
f.get() | |
ExecutorService e = ForkJoinPool.commonPool() | |
Future<String> f = e.submit(() -> "hello thessaloniki") | |
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 + " thessaloniki").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 | |
SimpleSubscriber sub = new SimpleSubscriber() | |
SubmissionPublisher<String> pub = new SubmissionPublisher<String>() | |
pub.subscribe(sub) | |
pub.getSubscribers() | |
pub.submit("hello thessaloniki") | |
pub.submit("hello thessaloniki") | |
pub.submit("hello thessaloniki") | |
pub.submit("hello thessaloniki") | |
pub.close() | |
pub.submit("hello thessaloniki") | |
HttpHandler handler = he -> { | |
String body = "hello thessaloniki"; | |
he.sendResponseHeaders(200, body.length()); | |
try (OutputStream os = he.getResponseBody()) { | |
os.write(body.getBytes()); | |
} | |
} | |
/l handler | |
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