Function run_subscriptions 

async fn run_subscriptions(
    client: &Client,
    public_key: &str,
    tx: &Sender<RealtimeEvent>,
    shutdown: CancellationToken,
) -> Result<(), Error>