public abstract long observeWm(int queueIndex, long wmValue);
@Test
    public void when_i1Idle_i2HasWm_then_forwardedImmediately() {
        assertEquals(Long.MIN_VALUE, wc.observeWm(0, IDLE_MESSAGE.timestamp()));
        assertEquals(100, wc.observeWm(1, 100));
    }