@Override
    synchronized long streamTime() {
        return wrapped.streamTime();
    }
@Test
    public void testStreamTime() {
        final long streamTime = 12345678L;
        when(wrapped.streamTime()).thenReturn(streamTime);

        final long result = synchronizedPartitionGroup.streamTime();

        assertEquals(streamTime, result);
        verify(wrapped, times(1)).streamTime();
    }