def METHOD_NAME(self, newBuildCallback, flushErrors=False):
    newConsumer = yield self.master.mq.startConsuming(
        newBuildCallback,
        ('builds', None, 'new'))
    build = yield self.doForceBuild(wantSteps=True,
                                    useChange=self.change,
                                    wantLogs=True)
    self.assertBuildIsCancelled(build)
    newConsumer.stopConsuming()
    builds = yield self.master.data.get(("builds",))
    for b in builds:
        self.assertBuildIsCancelled(b)
    if flushErrors:
        self.flushLoggedErrors()