Implement Activity Watching API

Implements the Watching API in both Async and Observable projects with unit tests.

Closes #327