Showing the changes to git-protocol/src/fetch/function.rs (1 of 3 files). Show all
Unified · Split
| @@ -140,7 +140,7 @@ where · 139 unmodified lines | |||
| 140 | refs::from_v2_refs(&mut remote_refs).await? | 140 | refs::from_v2_refs(&mut remote_refs).await? |
| 141 | } | 141 | } |
| 142 | Err(err) => { | 142 | Err(err) => { |
| 143 | indicate_end_of_interaction(transport)?; | 143 | indicate_end_of_interaction(transport).await?; |
| 144 | return Err(err.into()); | 144 | return Err(err.into()); |
| 145 | } | 145 | } |
| 146 | } | 146 | } |
| @@ -150,12 +150,12 @@ where · 3 unmodified lines | |||
| 150 | let fetch = Command::Fetch; | 150 | let fetch = Command::Fetch; |
| 151 | let mut fetch_features = fetch.default_features(protocol_version, &capabilities); | 151 | let mut fetch_features = fetch.default_features(protocol_version, &capabilities); |
| 152 | match delegate.prepare_fetch(protocol_version, &capabilities, &mut fetch_features, &parsed_refs) { | 152 | match delegate.prepare_fetch(protocol_version, &capabilities, &mut fetch_features, &parsed_refs) { |
| 153 | Ok(Action::Cancel) => return indicate_end_of_interaction(transport), | 153 | Ok(Action::Cancel) => return indicate_end_of_interaction(transport).await, |
| 154 | Ok(Action::Continue) => { | 154 | Ok(Action::Continue) => { |
| 155 | fetch.validate_argument_prefixes_or_panic(protocol_version, &capabilities, &[], &fetch_features); | 155 | fetch.validate_argument_prefixes_or_panic(protocol_version, &capabilities, &[], &fetch_features); |
| 156 | } | 156 | } |
| 157 | Err(err) => { | 157 | Err(err) => { |
| 158 | indicate_end_of_interaction(transport)?; | 158 | indicate_end_of_interaction(transport).await?; |
| 159 | return Err(err.into()); | 159 | return Err(err.into()); |
| 160 | } | 160 | } |
| 161 | } | 161 | } |