Wait for version before returning completions

This commit is contained in:
Antonio Scandurra 2022-02-17 11:41:19 +01:00
parent e824a6f220
commit 50a31721eb
4 changed files with 34 additions and 14 deletions

View file

@ -1401,15 +1401,14 @@ impl Project {
position: Some(language::proto::serialize_anchor(&anchor)),
version: (&source_buffer.version()).into(),
};
cx.spawn_weak(|_, cx| async move {
cx.spawn_weak(|_, mut cx| async move {
let response = rpc.request(message).await?;
if !source_buffer_handle
.read_with(&cx, |buffer, _| buffer.version())
.observed_all(&response.version.into())
{
Err(anyhow!("completion response depends on unreceived edits"))?;
}
source_buffer_handle
.update(&mut cx, |buffer, _| {
buffer.wait_for_version(response.version.into())
})
.await;
response
.completions