@@ -0,0 +1,823 @@
+package com.github.davidmoten.rx2;%0A%0Aimport static org.junit.Assert.assertEquals;%0Aimport static org.junit.Assert.assertNull;%0A%0Aimport org.junit.Test;%0A%0Apublic class MspcQueueTest %7B%0A%0A    @Test%0A    public void testEmptyQueuePoll() %7B%0A        MpscQueue%3CInteger%3E q = new MpscQueue%3CInteger%3E();%0A        assertNull(q.poll());%0A        assertNull(q.poll());%0A    %7D%0A%0A    @Test%0A    public void testPushPoll() %7B%0A        MpscQueue%3CInteger%3E q = new MpscQueue%3CInteger%3E();%0A        q.offer(1);%0A        assertEquals(1, (int) q.poll());%0A        assertNull(q.poll());%0A    %7D%0A    %0A    @Test%0A    public void testPushPushPollPoll() %7B%0A        MpscQueue%3CInteger%3E q = new MpscQueue%3CInteger%3E();%0A        q.offer(1);%0A        q.offer(2);%0A        assertEquals(1, (int) q.poll());%0A        assertEquals(2, (int) q.poll());%0A        assertNull(q.poll());%0A    %7D%0A%0A%7D%0A

test dev