import reactor.bus.EventBus;
import reactor.fn.Function;
import static reactor.bus.selector.Selectors.$;
public class EventBusSamples {
public static void main(String... args) {
<BUG>Environment env = new Environment();
EventBus r = EventBus.config()
.env(env)
.dispatcher(Environment.SHARED)</BUG>
.get();

import reactor.bus.EventBus;
import reactor.fn.Function;
import static reactor.bus.selector.Selectors.$;
public class EventBusSamples {
public static void main(String... args) {
EventBus r = EventBus.config()
.processor(Processors.topic())
.get();
