public class io.fabric.kubernetes.client.utils.internal.WatcherToggle extends java.lang.Object implements io.fabric.kubernetes.client.Watcher
{
private final io.fabric.kubernetes.client.Watcher delegate;
private boolean enabled;
public void <init>(io.fabric.kubernetes.client.Watcher, boolean)
{
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
io.fabric.kubernetes.client.Watcher v;
java.lang.Object v;
boolean v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v := @parameter: io.fabric.kubernetes.client.Watcher;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "delegate watcher cannot be null");
v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: io.fabric.kubernetes.client.Watcher delegate> = v;
v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: boolean enabled> = v;
return;
}
public void disable()
{
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: boolean enabled> = 0;
return;
}
public void enable()
{
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: boolean enabled> = 1;
return;
}
public void eventReceived(io.fabric.kubernetes.client.Watcher$Action, java.lang.Object)
{
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
io.fabric.kubernetes.client.Watcher$Action v;
io.fabric.kubernetes.client.Watcher v;
java.lang.Object v;
boolean v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v := @parameter: io.fabric.kubernetes.client.Watcher$Action;
v := @parameter: java.lang.Object;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: boolean enabled>;
if v == 0 goto label;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: io.fabric.kubernetes.client.Watcher delegate>;
interfaceinvoke v.<io.fabric.kubernetes.client.Watcher: void eventReceived(io.fabric.kubernetes.client.Watcher$Action,java.lang.Object)>(v, v);
label:
return;
}
public void onClose(io.fabric.kubernetes.client.WatcherException)
{
io.fabric.kubernetes.client.WatcherException v;
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
io.fabric.kubernetes.client.Watcher v;
boolean v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v := @parameter: io.fabric.kubernetes.client.WatcherException;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: boolean enabled>;
if v == 0 goto label;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: io.fabric.kubernetes.client.Watcher delegate>;
interfaceinvoke v.<io.fabric.kubernetes.client.Watcher: void onClose(io.fabric.kubernetes.client.WatcherException)>(v);
label:
return;
}
public void onClose()
{
io.fabric.kubernetes.client.Watcher v;
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
boolean v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: boolean enabled>;
if v == 0 goto label;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: io.fabric.kubernetes.client.Watcher delegate>;
interfaceinvoke v.<io.fabric.kubernetes.client.Watcher: void onClose()>();
label:
return;
}
public boolean reconnecting()
{
io.fabric.kubernetes.client.Watcher v;
io.fabric.kubernetes.client.utils.internal.WatcherToggle v;
boolean v;
v := @this: io.fabric.kubernetes.client.utils.internal.WatcherToggle;
v = v.<io.fabric.kubernetes.client.utils.internal.WatcherToggle: io.fabric.kubernetes.client.Watcher delegate>;
v = interfaceinvoke v.<io.fabric.kubernetes.client.Watcher: boolean reconnecting()>();
return v;
}
}