1 package com.github.davidmoten.rx.internal.operators; 2 3 import java.util.Queue; 4 5 import rx.Subscription; 6 7 public interface QueueWithSubscription<T> extends Queue<T>, Subscription { 8 9 }