class TupleForwarder {

    public void maybeForward(final K key,
                             final V newValue,
                             final V oldValue) {
        if (cachingEnabled) {
            return;
        }
        context.forward(key, new Change<>(newValue, oldValue));
    }

    @SuppressWarnings("unchecked")  TupleForwarder(final StateStore store,
                   final ProcessorContext context,
                   final ForwardingCacheFlushListener<K, V> flushListener,
                   final boolean sendOldValues);

}