class ObservableBuffer extends ObservableListBase<E> implements Queue<E> {

    @Override
    public E poll()
    {
        E removedItem = null;
        synchronized (myQueue)
        {
            beginChange();
            try
            {
                removedItem = myQueue.pollLast();
                nextRemove(0, removedItem);
            }
            finally
            {
                endChange();
            }
        }
        return removedItem;
    }

    public  ObservableBuffer(final int capacity);

}