public class io.smallrye.mutiny.groups.UniOnTimeout extends java.lang.Object
{
private final io.smallrye.mutiny.Uni failure;
private final java.time.Duration timeout;
private final java.util.concurrent.ScheduledExecutorService executor;
public void <init>(io.smallrye.mutiny.Uni, java.time.Duration, java.util.concurrent.ScheduledExecutorService)
{
java.time.Duration v;
io.smallrye.mutiny.groups.UniOnTimeout v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.Object v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: io.smallrye.mutiny.Uni;
v := @parameter: java.time.Duration;
v := @parameter: java.util.concurrent.ScheduledExecutorService;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "upstream");
v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni failure> = v;
v.<io.smallrye.mutiny.groups.UniOnTimeout: java.time.Duration timeout> = v;
v.<io.smallrye.mutiny.groups.UniOnTimeout: java.util.concurrent.ScheduledExecutorService executor> = v;
return;
}
public io.smallrye.mutiny.groups.UniOnTimeout after(java.time.Duration)
{
java.time.Duration v, v;
io.smallrye.mutiny.groups.UniOnTimeout v, v;
java.util.concurrent.ScheduledExecutorService v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.time.Duration;
v = new io.smallrye.mutiny.groups.UniOnTimeout;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni failure>;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.time.Duration validate(java.time.Duration,java.lang.String)>(v, "timeout");
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: java.util.concurrent.ScheduledExecutorService executor>;
specialinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: void <init>(io.smallrye.mutiny.Uni,java.time.Duration,java.util.concurrent.ScheduledExecutorService)>(v, v, v);
return v;
}
public io.smallrye.mutiny.groups.UniOnTimeout on(java.util.concurrent.ScheduledExecutorService)
{
java.time.Duration v;
io.smallrye.mutiny.groups.UniOnTimeout v, v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.Object v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.util.concurrent.ScheduledExecutorService;
v = new io.smallrye.mutiny.groups.UniOnTimeout;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni failure>;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: java.time.Duration timeout>;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "executor");
specialinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: void <init>(io.smallrye.mutiny.Uni,java.time.Duration,java.util.concurrent.ScheduledExecutorService)>(v, v, v);
return v;
}
public io.smallrye.mutiny.Uni fail()
{
io.smallrye.mutiny.groups.UniOnTimeout v;
java.util.function.Supplier v;
io.smallrye.mutiny.Uni v, v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v = staticinvoke <io.smallrye.mutiny.groups.UniOnTimeout$init__2999: java.util.function.Supplier bootstrap$()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni failWith(java.util.function.Supplier)>(v);
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.Uni onUniCreation(io.smallrye.mutiny.Uni)>(v);
return v;
}
public io.smallrye.mutiny.Uni failWith(java.lang.Throwable)
{
java.lang.Throwable v;
io.smallrye.mutiny.groups.UniOnTimeout v;
java.util.function.Supplier v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.lang.Throwable;
v = staticinvoke <io.smallrye.mutiny.groups.UniOnTimeout$lambda_failWith_0__3000: java.util.function.Supplier bootstrap$(java.lang.Throwable)>(v);
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni failWith(java.util.function.Supplier)>(v);
return v;
}
public io.smallrye.mutiny.Uni failWith(java.util.function.Supplier)
{
io.smallrye.mutiny.operators.uni.UniFailOnTimeout v;
java.util.function.Supplier v, v;
io.smallrye.mutiny.Uni v, v;
java.time.Duration v, v;
io.smallrye.mutiny.groups.UniOnTimeout v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.Object v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.util.function.Supplier;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: java.time.Duration timeout>;
staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.time.Duration validate(java.time.Duration,java.lang.String)>(v, "timeout");
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "supplier");
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.Supplier decorate(java.util.function.Supplier)>(v);
v = new io.smallrye.mutiny.operators.uni.UniFailOnTimeout;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni failure>;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: java.time.Duration timeout>;
v = v.<io.smallrye.mutiny.groups.UniOnTimeout: java.util.concurrent.ScheduledExecutorService executor>;
specialinvoke v.<io.smallrye.mutiny.operators.uni.UniFailOnTimeout: void <init>(io.smallrye.mutiny.Uni,java.time.Duration,java.util.function.Supplier,java.util.concurrent.ScheduledExecutorService)>(v, v, v, v);
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.Uni onUniCreation(io.smallrye.mutiny.Uni)>(v);
return v;
}
public io.smallrye.mutiny.Uni recoverWithItem(java.lang.Object)
{
io.smallrye.mutiny.groups.UniOnFailure v;
io.smallrye.mutiny.groups.UniOnTimeout v;
java.lang.Object v;
io.smallrye.mutiny.Uni v, v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni fail()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniOnFailure onFailure(java.lang.Class)>(class "Lio/smallrye/mutiny/TimeoutException;");
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnFailure: io.smallrye.mutiny.Uni recoverWithItem(java.lang.Object)>(v);
return v;
}
public io.smallrye.mutiny.Uni recoverWithItem(java.util.function.Supplier)
{
io.smallrye.mutiny.groups.UniOnFailure v;
io.smallrye.mutiny.groups.UniOnTimeout v;
java.util.function.Supplier v;
io.smallrye.mutiny.Uni v, v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.util.function.Supplier;
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni fail()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniOnFailure onFailure(java.lang.Class)>(class "Lio/smallrye/mutiny/TimeoutException;");
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnFailure: io.smallrye.mutiny.Uni recoverWithItem(java.util.function.Supplier)>(v);
return v;
}
public io.smallrye.mutiny.Uni recoverWithUni(java.util.function.Supplier)
{
io.smallrye.mutiny.groups.UniOnFailure v;
io.smallrye.mutiny.groups.UniOnTimeout v;
java.util.function.Supplier v;
io.smallrye.mutiny.Uni v, v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: java.util.function.Supplier;
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni fail()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniOnFailure onFailure(java.lang.Class)>(class "Lio/smallrye/mutiny/TimeoutException;");
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnFailure: io.smallrye.mutiny.Uni recoverWithUni(java.util.function.Supplier)>(v);
return v;
}
public io.smallrye.mutiny.Uni recoverWithUni(io.smallrye.mutiny.Uni)
{
io.smallrye.mutiny.groups.UniOnFailure v;
io.smallrye.mutiny.groups.UniOnTimeout v;
io.smallrye.mutiny.Uni v, v, v;
v := @this: io.smallrye.mutiny.groups.UniOnTimeout;
v := @parameter: io.smallrye.mutiny.Uni;
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnTimeout: io.smallrye.mutiny.Uni fail()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniOnFailure onFailure(java.lang.Class)>(class "Lio/smallrye/mutiny/TimeoutException;");
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnFailure: io.smallrye.mutiny.Uni recoverWithUni(io.smallrye.mutiny.Uni)>(v);
return v;
}
}