refactor StreamCatchUpSubscriptionActor.subscribe