import reactor.rx.Promise;
import reactor.rx.broadcast.Broadcaster;
<BUG>import static reactor.Environment.get;</BUG>
public class StreamSamples {
static final Logger LOG = LoggerFactory.getLogger(StreamSamples.class);
<BUG>static {
Environment.initializeIfEmpty()
.assignErrorJournal();
}</BUG>
public static void main(String... args) throws InterruptedException {

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 {
