Sha256: 5888c8ebc2e96b93dea29e2fc5ac992ec3af9a8468b49b2e900f27c790cacf2f
Contents?: true
Size: 1.73 KB
Versions: 4
Compression:
Stored size: 1.73 KB
Contents
package org.mortbay.cometd.ext;
import junit.framework.TestCase;
public class ArrayIdQueueTest extends TestCase
{
public void testQueue() throws Exception
{
ArrayIdQueue<String> queue = new ArrayIdQueue<String>(3);
int id=10;
queue.setCurrentId(id);
assertEquals(0,queue.size());
for (int i=0;i<10;i++)
{
assertEquals(10+i,id);
queue.offer("one");
assertEquals(1,queue.size());
queue.offer("two");
assertEquals(2,queue.size());
queue.incrementCurrentId();
queue.offer("three");
assertEquals(3,queue.size());
assertEquals("one",queue.get(0));
assertEquals(id,queue.getAssociatedId(0));
assertEquals("two",queue.get(1));
assertEquals(id,queue.getAssociatedId(1));
assertEquals("three",queue.get(2));
assertEquals(id+1,queue.getAssociatedId(2));
assertEquals("[one, two, three]",queue.toString());
assertEquals("two",queue.remove(1));
assertEquals(2,queue.size());
assertEquals("one",queue.remove());
assertEquals(1,queue.size());
assertEquals("three",queue.poll());
assertEquals(0,queue.size());
assertEquals(null,queue.poll());
assertEquals(0,queue.size());
queue.offer("xxx");
queue.offer("xxx");
assertEquals(2,queue.size());
assertEquals("xxx",queue.poll());
assertEquals("xxx",queue.poll());
assertEquals(0,queue.size());
id++;
}
}
}
Version data entries
4 entries across 4 versions & 1 rubygems