Skip to content

Commit

Permalink
add accessor to emitters created by observer
Browse files Browse the repository at this point in the history
  • Loading branch information
tamland committed Sep 5, 2014
1 parent de5a60e commit 5ba73b9
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 4 deletions.
5 changes: 5 additions & 0 deletions src/watchdog/observers/api.py
Original file line number Diff line number Diff line change
Expand Up @@ -245,6 +245,11 @@ def _add_handler_for_watch(self, event_handler, watch):
def _remove_handlers_for_watch(self, watch):
del self._handlers[watch]

@property
def emitters(self):
"""Returns event emitter created by this observer."""
return self._emitters

def start(self):
for emitter in self._emitters:
emitter.start()
Expand Down
8 changes: 4 additions & 4 deletions tests/test_observer.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,27 +36,27 @@ def finalizer():
def test_schedule_should_start_emitter_if_running(observer):
observer.start()
observer.schedule(None, '')
(emitter,) = observer._emitters
(emitter,) = observer.emitters
assert emitter.is_alive()


def test_schedule_should_not_start_emitter_if_not_running(observer):
observer.schedule(None, '')
(emitter,) = observer._emitters
(emitter,) = observer.emitters
assert not emitter.is_alive()


def test_start_should_start_emitter(observer):
observer.schedule(None, '')
observer.start()
(emitter,) = observer._emitters
(emitter,) = observer.emitters
assert emitter.is_alive()


def test_stop_should_stop_emitter(observer):
observer.schedule(None, '')
observer.start()
(emitter,) = observer._emitters
(emitter,) = observer.emitters
assert emitter.is_alive()
observer.stop()
observer.join()
Expand Down

0 comments on commit 5ba73b9

Please sign in to comment.