Made this class only be responsible for synchronization, not contract enforcement.

It was colliding with error handling logic in `SafeSubscriber` and swallowing errors trying to be thrown.