class io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper extends java.lang.Object implements java.util.concurrent.ScheduledExecutorService
{
private final java.util.concurrent.ScheduledExecutorService delegate;
private final java.util.function.Supplier contextSupplier;
void <init>(java.util.concurrent.ScheduledExecutorService, java.util.function.Supplier)
{
java.util.concurrent.ScheduledExecutorService v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.util.function.Supplier v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.concurrent.ScheduledExecutorService;
v := @parameter: java.util.function.Supplier;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate> = v;
v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.function.Supplier contextSupplier> = v;
return;
}
private java.lang.Runnable decorate(java.lang.Runnable)
{
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper$lambda_decorate_0__2046: java.lang.Runnable bootstrap$(io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper,java.lang.Runnable)>(v, v);
return v;
}
public java.util.concurrent.ScheduledFuture schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.util.concurrent.ScheduledFuture v;
java.util.concurrent.ScheduledExecutorService v;
long v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate>;
v = specialinvoke v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.lang.Runnable decorate(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture schedule(java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public java.util.concurrent.ScheduledFuture schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
java.util.concurrent.Callable v;
long v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.ScheduledFuture v;
long v, v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.ScheduledExecutorService v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate>;
v = specialinvoke v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.lang.Runnable decorate(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
return v;
}
public java.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.ScheduledFuture v;
long v, v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.ScheduledExecutorService v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate>;
v = specialinvoke v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.lang.Runnable decorate(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
return v;
}
public void shutdown()
{
java.lang.UnsupportedOperationException v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.util.List shutdownNow()
{
java.lang.UnsupportedOperationException v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public boolean isShutdown()
{
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
return 0;
}
public boolean isTerminated()
{
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
return 0;
}
public boolean awaitTermination(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
long v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.util.concurrent.Future submit(java.util.concurrent.Callable)
{
java.lang.UnsupportedOperationException v;
java.util.concurrent.Callable v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.concurrent.Callable;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.util.concurrent.Future submit(java.lang.Runnable, java.lang.Object)
{
java.util.concurrent.Future v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.Object v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
v = v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate>;
v = specialinvoke v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.lang.Runnable decorate(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.Future submit(java.lang.Runnable,java.lang.Object)>(v, v);
return v;
}
public java.util.concurrent.Future submit(java.lang.Runnable)
{
java.util.concurrent.Future v;
java.util.concurrent.ScheduledExecutorService v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v = v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate>;
v = specialinvoke v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.lang.Runnable decorate(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
return v;
}
public java.util.List invokeAll(java.util.Collection)
{
java.lang.UnsupportedOperationException v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.util.Collection v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.Collection;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.util.List invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
java.util.Collection v;
long v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.lang.Object invokeAny(java.util.Collection)
{
java.lang.UnsupportedOperationException v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.util.Collection v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.Collection;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public java.lang.Object invokeAny(java.util.Collection, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
java.util.Collection v;
long v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public void execute(java.lang.Runnable)
{
java.util.concurrent.ScheduledExecutorService v;
io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper v;
java.lang.Runnable v, v;
v := @this: io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper;
v := @parameter: java.lang.Runnable;
v = v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.util.concurrent.ScheduledExecutorService delegate>;
v = specialinvoke v.<io.smallrye.mutiny.vertx.core.ContextAwareExecutorWrapper: java.lang.Runnable decorate(java.lang.Runnable)>(v);
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: void execute(java.lang.Runnable)>(v);
return;
}
}