Skip to content

Commit 1315652

Browse files
Update src/flow_service/mod.rs
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Signed-off-by: Raphael Götz <52959657+raphael-goetz@users.noreply.github.com>
1 parent 478f7cd commit 1315652

1 file changed

Lines changed: 4 additions & 9 deletions

File tree

src/flow_service/mod.rs

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -245,15 +245,10 @@ impl FlowUpdateService {
245245
return true;
246246
}
247247

248-
self.flow_types = self
249-
.flow_types
250-
.clone()
251-
.into_iter()
252-
.map(|mut x| {
253-
x.definition_source = self.definition_source.clone();
254-
x
255-
})
256-
.collect();
248+
let definition_source = self.definition_source.clone();
249+
for flow_type in self.flow_types.iter_mut() {
250+
flow_type.definition_source = definition_source.clone();
251+
}
257252

258253
log::info!("Updating {} FlowTypes.", self.flow_types.len());
259254
let mut client = FlowTypeServiceClient::new(self.channel.clone());

0 commit comments

Comments
 (0)