We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 208c4d9 + cdc480a commit b611c18Copy full SHA for b611c18
server/swimos_agent/src/agent_model/mod.rs
@@ -1006,6 +1006,15 @@ where
1006
lane_readers.push(LaneReader::http(id, rx));
1007
}
1008
1009
+ // We need to check if anything has been written into the command buffer as the agent
1010
+ // initialisation process called lifecycle::on_start and that may have sent commands.
1011
+ check_cmds(
1012
+ &mut ad_hoc_buffer,
1013
+ &mut cmd_writer,
1014
+ &mut cmd_send_fut,
1015
+ CommandWriter::write,
1016
+ );
1017
+
1018
// This set keeps track of which items have data to be written (according to executed event handlers).
1019
let mut dirty_items: HashSet<u64> = HashSet::new();
1020
0 commit comments