Removed I/O scheduler so that subscriptions run in the calling thread.