next();
stream.onNext("Hello World!");
promise.await();
}
private static void transformValues() throws InterruptedException {
<BUG>Broadcaster<String> stream = Broadcaster.create(get());
Promise<String> promise = stream.</BUG>
map(String::toUpperCase).
observe(s -> LOG.info("UC String {}", s)).
next();

next();
stream.onNext("Hello World!");
promise.await();
}
private static void transformValues() throws InterruptedException {
Broadcaster<String> stream = Broadcaster.create();
Promise<String> promise = stream.
map(String::toUpperCase).
observe(s -> LOG.info("UC String {}", s)).
next();
