|
|
@ -5,6 +5,9 @@ use std::sync::atomic::AtomicBool;
|
|
|
|
use std::mem::MaybeUninit;
|
|
|
|
use std::mem::MaybeUninit;
|
|
|
|
use std::cell::UnsafeCell;
|
|
|
|
use std::cell::UnsafeCell;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// This was a failure. Just use `tokio::sync::oneshot`...
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
#[derive(Debug)]
|
|
|
|
#[derive(Debug)]
|
|
|
|
struct SharedInitialiser<T>
|
|
|
|
struct SharedInitialiser<T>
|
|
|
|
{
|
|
|
|
{
|
|
|
@ -95,3 +98,4 @@ impl<T> SharedInitRx<T>
|
|
|
|
Arc::strong_count(&self.0.data) == 2
|
|
|
|
Arc::strong_count(&self.0.data) == 2
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
*/
|
|
|
|