}</BUG>
public static void main(String... args) throws InterruptedException {
simpleStream();
transformValues();
filterValues();
<BUG>get().shutdown();</BUG>
}
private static void simpleStream() throws InterruptedException {
<BUG>Broadcaster<String> stream = Broadcaster.create(get());
Promise<String> promise = stream.</BUG>
observe(s -> LOG.info("Consumed String {}", s)).

import reactor.rx.Promise;
import reactor.rx.broadcast.Broadcaster;
public class StreamSamples {
static final Logger LOG = LoggerFactory.getLogger(StreamSamples.class);
public static void main(String... args) throws InterruptedException {
simpleStream();
transformValues();
filterValues();
}
private static void simpleStream() throws InterruptedException {
Broadcaster<String> stream = Broadcaster.create();
Promise<String> promise = stream.
observe(s -> LOG.info("Consumed String {}", s)).
