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