QueueLibraryManager.java

import rx.Observable;

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * Created by harshitbangar on 19/08/16.
 */
public class QueueLibraryManager {

    Queue<QueueLibrary> strings = new ConcurrentLinkedQueue<QueueLibrary>();

    public Observable<String> addToQueue(String s) {
        QueueLibrary queueLibrary = new QueueLibrary(s);
        strings.add(queueLibrary);
        return queueLibrary.stringPublishSubject;
    }

    public QueueLibraryManager() {
        ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor();
        exec.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                while (!strings.isEmpty()) {
                    QueueLibrary queueLibrary = strings.poll();
                    queueLibrary.stringPublishSubject.onNext(queueLibrary.s);
                }
            }
        }, 0, 5, TimeUnit.SECONDS);
    }
}