package com.oath.cyclops.react.async.subscription;

import com.oath.cyclops.async.adapters.Queue;

public class AlwaysContinue implements Continueable {

    /* (non-Javadoc)
     * @see Continueable#closeQueueIfFinished(cyclops2.async.Queue)
     */
    @Override
    public void closeQueueIfFinished(final Queue queue) {

    }

    /* (non-Javadoc)
     * @see Continueable#addQueue(cyclops2.async.Queue)
     */
    @Override
    public void addQueue(final Queue queue) {

    }

    /* (non-Javadoc)
     * @see Continueable#registerSkip(long)
     */
    @Override
    public void registerSkip(final long skip) {

    }

    /* (non-Javadoc)
     * @see Continueable#registerLimit(long)
     */
    @Override
    public void registerLimit(final long limit) {

    }

    /* (non-Javadoc)
     * @see Continueable#closeAll(cyclops2.async.Queue)
     */
    @Override
    public void closeAll(final Queue queue) {

    }

    /* (non-Javadoc)
     * @see Continueable#closed()
     */
    @Override
    public boolean closed() {

        return false;
    }

    /* (non-Javadoc)
     * @see Continueable#closeQueueIfFinishedStateless(cyclops2.async.Queue)
     */
    @Override
    public void closeQueueIfFinishedStateless(final Queue queue) {

    }

    /* (non-Javadoc)
     * @see Continueable#closeAll()
     */
    @Override
    public void closeAll() {

    }

    /* (non-Javadoc)
     * @see Continueable#timeLimit()
     */
    @Override
    public long timeLimit() {

        return -1;
    }

    /* (non-Javadoc)
     * @see Continueable#registerTimeLimit(long)
     */
    @Override
    public void registerTimeLimit(final long nanos) {

    }
}
