import com.google.common.reflect.AbstractInvocationHandler;
import com.google.common.reflect.Reflection;
import io.netty.util.concurrent.EventExecutor;
-
+import io.netty.util.concurrent.GlobalEventExecutor;
+import io.netty.util.concurrent.ImmediateEventExecutor;
import java.lang.reflect.Method;
import java.util.concurrent.TimeUnit;
}
- public static AutoCloseable createCloseableProxy(final EventExecutor eventExecutor) {
+ private static AutoCloseableEventExecutor createCloseableProxy(final EventExecutor eventExecutor) {
final CloseableEventExecutorMixin closeableGlobalEventExecutorMixin =
new CloseableEventExecutorMixin(eventExecutor);
return Reflection.newProxy(AutoCloseableEventExecutor.class, new AbstractInvocationHandler() {
});
}
+ public static AutoCloseableEventExecutor globalEventExecutor() {
+ return createCloseableProxy(GlobalEventExecutor.INSTANCE);
+ }
+ public static AutoCloseableEventExecutor immediateEventExecutor() {
+ return createCloseableProxy(ImmediateEventExecutor.INSTANCE);
+ }
}
}
\ No newline at end of file