refactoring: use thread-safe Subscriptions.create()