Lines Matching refs:task_string
67 pub task_string: String, field
77 task_string: String, in new()
84 task_string, in new()
140 forward_info.task_string.clone(), in put()
156 pub async fn remove_forward(task_string: String, forward_direction: bool) -> bool { in remove_forward()
159 task_string, in remove_forward()
171 task_string1.push_str(task_string.as_str()); in remove_forward()
174 if info.task_string.contains(&task_string1) in remove_forward()
352 pub async fn get_channel_id(session_id: u32, task_string: String) -> Option<u32> { in get_channel_id()
356 if *_session_id == session_id && task_string.contains(&value.task_command) { in get_channel_id()
545 let task_string = String::from_utf8(payload); in on_forward_success() localVariable
546 match task_string { in on_forward_success()
547 Ok(task_string) => { in on_forward_success()
552 task_string, in on_forward_success()