throw new NoSuchMethodError(method.getName());
}
}
private Reactor createReactor(Dispatcher dispatcherAnnotation) {
ReactorSpec reactorSpec = Reactors.reactor().env(env);
if(dispatcherAnnotation != null) {
if("sync".equals(dispatcherAnnotation.value())) {
reactorSpec.dispatcher(SynchronousDispatcher.INSTANCE);
} else {
reactorSpec.dispatcher(dispatcherAnnotation.value());
}
}
return reactorSpec.get();
}