def payloadSerializer = Mock(PayloadSerializer)

    def "ignores unknown operation types"() {
        given:
        def parameters = Stub(ProviderOperationParameters) {
            getBuildProgressListener() >> Stub(InternalBuildProgressListener) {
                getSubscribedOperations() >> ["UNKNOWN_OPERATION"]
            }
        }

        when:

    }

    @Override
    public <T> T run(ConsumerAction<T> action) throws UnsupportedOperationException, IllegalStateException {
        T result = delegate.run(action);
        action.getParameters().getBuildProgressListener().rethrowErrors();
        action.getParameters().getStreamedValueListener().rethrowErrors();
        return result;
    }

    @Override
    public void disconnect() {
        delegate.disconnect();

            ConsumerOperationParameters parameters = action.getParameters();
            this.cancellationToken = parameters.getCancellationToken();
            InternalBuildProgressListener buildProgressListener = parameters.getBuildProgressListener();
            ConsumerConnection connection = onStartAction(cancellationToken, buildProgressListener);
            return action.run(connection);
        } finally {
            onEndAction();
        }

    /**
     * @return When null, do not forward any build progress events.
     * @since 2.4-rc-1
     */
    @Nullable
    InternalBuildProgressListener getBuildProgressListener();

    /**
     * @return When null, assume no arguments.
     */
    @Nullable
    List<String> getArguments();

    /**

     */
    public ProgressListenerVersion1 getProgressListener() {
        return progressListener;
    }

    /**
     * @since 2.4-rc-1
     */
    public FailsafeBuildProgressListenerAdapter getBuildProgressListener() {
        return buildProgressListener;
    }

    public BuildCancellationToken getCancellationToken() {
        return ((CancellationTokenInternal) cancellationToken).getToken();
    }

            GradleVersion consumerVersion,
            PayloadSerializer payloadSerializer
        ) {
            InternalBuildProgressListener buildProgressListener = providerParameters.getBuildProgressListener();
            Set<OperationType> operationTypes = toOperationTypes(buildProgressListener, consumerVersion);
            BuildEventSubscriptions clientSubscriptions = new BuildEventSubscriptions(operationTypes);