pub fn for_each_thread_stream( fun: &mut dyn FnMut(*mut EventStream<EventBlock<ThreadEventQueue>>), )