def test_subscribed_event(self):
    test_event = dict(subscription='test3', msg='blah')

    with self.setup_subscribed([test_event]):
      out = self.watchman.subscribed(self.BUILD_ROOT, self.HANDLERS)
      self.assertEquals(list(out), [('test3', test_event)])
Test yielding on a watchman event for a given subscription.
dataset/ETHPy150Open pantsbuild/pants/tests/python/pants_test/pantsd/test_watchman.py/TestWatchman.test_subscribed_event