

package hu.akarnokd.experiments.concurrent.multiqueue;

import rx.functions.Action2;

/**
 * 
 */
public interface Queue2<T1, T2> extends QueueBase {
    boolean offer(T1 t1, T2 t2);
    
    boolean poll(Action2<? super T1, ? super T2> out);
    
    boolean peek(Action2<? super T1, ? super T2> out);
}
