public abstract class com.google.common.util.concurrent.ForwardingBlockingQueue extends com.google.common.collect.ForwardingQueue implements java.util.concurrent.BlockingQueue
{
protected void <init>()
{
com.google.common.util.concurrent.ForwardingBlockingQueue v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
specialinvoke v.<com.google.common.collect.ForwardingQueue: void <init>()>();
return;
}
protected abstract java.util.concurrent.BlockingQueue delegate();
public int drainTo(java.util.Collection, int)
{
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.util.Collection v;
int v, v;
java.util.concurrent.BlockingQueue v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v := @parameter: java.util.Collection;
v := @parameter: int;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int drainTo(java.util.Collection,int)>(v, v);
return v;
}
public int drainTo(java.util.Collection)
{
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.util.Collection v;
int v;
java.util.concurrent.BlockingQueue v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v := @parameter: java.util.Collection;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int drainTo(java.util.Collection)>(v);
return v;
}
public boolean offer(java.lang.Object, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.lang.Object v;
java.util.concurrent.BlockingQueue v;
long v;
boolean v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v := @parameter: java.lang.Object;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean offer(java.lang.Object,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public java.lang.Object poll(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.lang.Object v;
java.util.concurrent.BlockingQueue v;
long v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
public void put(java.lang.Object) throws java.lang.InterruptedException
{
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.lang.Object v;
java.util.concurrent.BlockingQueue v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
interfaceinvoke v.<java.util.concurrent.BlockingQueue: void put(java.lang.Object)>(v);
return;
}
public int remainingCapacity()
{
int v;
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.util.concurrent.BlockingQueue v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int remainingCapacity()>();
return v;
}
public java.lang.Object take() throws java.lang.InterruptedException
{
com.google.common.util.concurrent.ForwardingBlockingQueue v;
java.lang.Object v;
java.util.concurrent.BlockingQueue v;
v := @this: com.google.common.util.concurrent.ForwardingBlockingQueue;
v = virtualinvoke v.<com.google.common.util.concurrent.ForwardingBlockingQueue: java.util.concurrent.BlockingQueue delegate()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object take()>();
return v;
}
}