Function proxy_remote 

pub async fn proxy_remote<T, F>(
    remote_sub: RemoteSubscription,
    sender: UnboundedSender<T>,
    shutdown: Receiver<bool>,
    convert: F,
)
where
    T: Send + 'static,
    F: Fn(RawChangePayload) -> T,