then:
        1 * buildProgressListener.subscribedOperations >> [InternalBuildProgressListener.FILE_DOWNLOAD]
        1 * cancellationToken.addCallback(_)

        then:
        1 * progressLoggerFactory.newOperation(DistributionInstaller.class) >>> loggerOne
        1 * buildProgressListener.onEvent({it instanceof StartEvent})

        1 * params.cancellationToken >> cancellationToken
        1 * params.buildProgressListener >> buildProgressListener
        1 * action.run(consumerConnection)
        0 * _._

        then:
        _ * action2.parameters >> params
        _ * params.cancellationToken >> cancellationToken
        1 * params.buildProgressListener >> buildProgressListener
        1 * action2.run(consumerConnection)
        0 * _._
    }

        this.progressLoggerFactory = progressLoggerFactory;
        this.buildProgressListener = getListener(buildProgressListener);
        this.clock = clock;
    }

    private InternalBuildProgressListener getListener(InternalBuildProgressListener buildProgressListener) {

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

        private final InternalBuildProgressListener buildProgressListener;

        private BuildProgressListenerInvokingBuildEventConsumer(InternalBuildProgressListener buildProgressListener) {
            this.buildProgressListener = buildProgressListener;
        }

        @Override
        public void dispatch(Object event) {

        }
    }

    private final String entryPointName;
    private final ProgressListenerAdapter progressListener;
    private final FailsafeBuildProgressListenerAdapter buildProgressListener;
    private final CancellationToken cancellationToken;
    private final ConnectionParameters parameters;
    private final long startTime = System.currentTimeMillis();

    private final OutputStream stdout;

        1 * target.run(action)
        1 * progressLogger.completed()
        1 * listenerManager.removeListener(!null)
        _ * params.progressListener >> listener
        _ * params.buildProgressListener >> buildListener
        _ * action.parameters >> params
        0 * _._
    }