WithSubscriptionFunc: ((session: ClientSession, subscription: ClientSubscription) => Promise<void>)