public class io.smallrye.mutiny.vertx.MutinyHelper extends java.lang.Object
{
public void <init>()
{
io.smallrye.mutiny.vertx.MutinyHelper v;
v := @this: io.smallrye.mutiny.vertx.MutinyHelper;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.util.concurrent.Executor executor(io.vertx.core.Vertx)
{
io.vertx.core.Vertx v;
java.util.concurrent.Executor v;
v := @parameter: io.vertx.core.Vertx;
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper$lambda_executor_1__2316: java.util.concurrent.Executor bootstrap$(io.vertx.core.Vertx)>(v);
return v;
}
public static java.util.concurrent.Executor executor(io.vertx.core.Context)
{
io.vertx.core.Context v;
java.util.concurrent.Executor v;
v := @parameter: io.vertx.core.Context;
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper$lambda_executor_3__2317: java.util.concurrent.Executor bootstrap$(io.vertx.core.Context)>(v);
return v;
}
public static java.util.concurrent.Executor blockingExecutor(io.vertx.core.Vertx)
{
io.vertx.core.Vertx v;
java.util.concurrent.Executor v;
v := @parameter: io.vertx.core.Vertx;
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper$lambda_blockingExecutor_5__2318: java.util.concurrent.Executor bootstrap$(io.vertx.core.Vertx)>(v);
return v;
}
public static java.util.concurrent.Executor blockingExecutor(io.vertx.core.Vertx, boolean)
{
io.vertx.core.Vertx v;
java.util.concurrent.Executor v;
boolean v;
v := @parameter: io.vertx.core.Vertx;
v := @parameter: boolean;
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper$lambda_blockingExecutor_7__2319: java.util.concurrent.Executor bootstrap$(io.vertx.core.Vertx,boolean)>(v, v);
return v;
}
public static java.util.concurrent.Executor blockingExecutor(io.vertx.core.WorkerExecutor)
{
java.util.concurrent.Executor v;
io.vertx.core.WorkerExecutor v;
v := @parameter: io.vertx.core.WorkerExecutor;
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper$lambda_blockingExecutor_9__2320: java.util.concurrent.Executor bootstrap$(io.vertx.core.WorkerExecutor)>(v);
return v;
}
public static java.lang.Class unwrap(java.lang.Class)
{
java.lang.'annotation'.Annotation v;
java.lang.Class v, v;
v := @parameter: java.lang.Class;
if v == null goto label;
v = virtualinvoke v.<java.lang.Class: java.lang.'annotation'.Annotation getAnnotation(java.lang.Class)>(class "Lio/smallrye/mutiny/vertx/MutinyGen;");
if v == null goto label;
v = interfaceinvoke v.<io.smallrye.mutiny.vertx.MutinyGen: java.lang.Class value()>();
return v;
label:
return v;
}
public static io.smallrye.mutiny.vertx.WriteStreamSubscriber toSubscriber(io.vertx.core.streams.WriteStream)
{
io.smallrye.mutiny.vertx.WriteStreamSubscriber v;
java.util.function.Function v;
io.vertx.core.streams.WriteStream v;
v := @parameter: io.vertx.core.streams.WriteStream;
v = staticinvoke <java.util.function.Function: java.util.function.Function identity()>();
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper: io.smallrye.mutiny.vertx.WriteStreamSubscriber toSubscriber(io.vertx.core.streams.WriteStream,java.util.function.Function)>(v, v);
return v;
}
public static io.smallrye.mutiny.vertx.WriteStreamSubscriber toSubscriber(io.vertx.core.streams.WriteStream, java.util.function.Function)
{
java.util.function.Function v;
io.vertx.core.streams.WriteStream v;
io.smallrye.mutiny.vertx.impl.WriteStreamSubscriberImpl v;
v := @parameter: io.vertx.core.streams.WriteStream;
v := @parameter: java.util.function.Function;
v = new io.smallrye.mutiny.vertx.impl.WriteStreamSubscriberImpl;
specialinvoke v.<io.smallrye.mutiny.vertx.impl.WriteStreamSubscriberImpl: void <init>(io.vertx.core.streams.WriteStream,java.util.function.Function)>(v, v);
return v;
}
}