public long getBytesOutCounter() {
        return bytesOutFromRemovedConsumers.longValue() + sumConsumers(Consumer::getBytesOutCounter);
    }
@Test
    public void testGetBytesOutCounter() {
        subscription.bytesOutFromRemovedConsumers.add(1L);
        when(consumer.getBytesOutCounter()).thenReturn(2L);
        assertEquals(subscription.getBytesOutCounter(), 3L);
    }