async def _handle_subscription_body(self, subscription_body: SubscriptionBody) -> None:
    if isinstance(subscription_body, TypeErrorSubscription):
        (await self.handle_type_error_subscription(subscription_body))
    elif isinstance(subscription_body, StatusUpdateSubscription):
        (await self.handle_status_update_subscription(subscription_body))
async def _handle_subscription_body(self, subscription_body: SubscriptionBody) -> None:
    if isinstance(subscription_body, TypeErrorSubscription):
        (await self.handle_type_error_subscription(subscription_body))
    elif isinstance(subscription_body, StatusUpdateSubscription):
        (await self.handle_status_update_subscription(subscription_body))