'Start async inputs; changefeeds etc'

@contextmanager
def start(self):

    for p in self.processes:
        p.start()
    time.sleep(0.2)
    try:
        (yield)
    finally:
        for p in self.processes:
            p.terminate()
