Lines Matching refs:task_string
65 pub task_string: String, field
75 task_string: String, in new()
82 task_string, in new()
138 forward_info.task_string.clone(), in put()
154 pub async fn remove_forward(task_string: String, forward_direction: bool) -> bool { in remove_forward()
157 task_string, in remove_forward()
169 task_string1.push_str(task_string.as_str()); in remove_forward()
172 if info.task_string.contains(&task_string1) in remove_forward()
353 pub async fn get_channel_id(session_id: u32, task_string: String) -> Option<u32> { in get_channel_id()
357 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()