try {
                    dispatchMessages(dispatch);
                } finally {
                    onDispatchThreadExit(dispatch);
                }
            }
        });
        onDispatchThreadStart(dispatch, dispatcher);
        executor.execute(CurrentBuildOperationPreservingRunnable.wrapIfNeeded(dispatcher));
    }

    private void dispatchMessages(Dispatch<? super T> dispatch) {
        while (true) {