import javax.annotation.Nullable;
import java.util.Collections;

public class FailsafeStreamedValueListener implements StreamedValueListener {
    @Nullable
    private final StreamedValueListener delegate;
    private RuntimeException failure;

    public FailsafeStreamedValueListener(@Nullable StreamedValueListener delegate) {
        this.delegate = delegate;
    }

    @Override

                legacyProgressListeners, progressListeners, cancellationToken, systemProperties, new FailsafeStreamedValueListener(streamedValueListener));
        }

        public void copyFrom(ConsumerOperationParameters operationParameters) {
            tasks = operationParameters.tasks;