pub async fn connect(params: Params) -> Result<impl Stream<Item = DepthDiff>>