Searched defs:push_thread (Results 1 – 1 of 1) sorted by relevance
375 let push_thread = thread::spawn(move || { in test_worker_push_block() localVariable409 let push_thread = thread::spawn(move || channel.push(task_cloned)); in test_worker_close_on_push_blocked() localVariable