package org.projectreactor.samples;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
<BUG>import reactor.Environment;</BUG>
import reactor.rx.Promise;
import reactor.rx.broadcast.Broadcaster;
<BUG>import static reactor.Environment.get;</BUG>
public class StreamSamples {

package org.projectreactor.samples;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import reactor.rx.Promise;
import reactor.rx.broadcast.Broadcaster;
public class StreamSamples {
