(
&self,
session_id: &str,
message_id: &str,
part: Part,
)
| 1102 | } |
| 1103 | |
| 1104 | async fn update_part( |
| 1105 | &self, |
| 1106 | session_id: &str, |
| 1107 | message_id: &str, |
| 1108 | part: Part, |
| 1109 | ) -> anyhow::Result<()> { |
| 1110 | self.parts |
| 1111 | .lock() |
| 1112 | .await |
| 1113 | .push((session_id.to_string(), message_id.to_string(), part)); |
| 1114 | Ok(()) |
| 1115 | } |
| 1116 | } |
| 1117 | |
| 1118 | fn make_input( |
no outgoing calls
no test coverage detected