@Override
    public <K, V> void forward(final K key, final V value) {
        throw new StreamsException(EXPLANATION);
    }
@Test
    public void shouldThrowOnForward() {
        assertThrows(StreamsException.class, () -> context.forward("key", "value"));
    }