pub fn abort(&self) {
        self.inner.aborted.store(true, Ordering::Relaxed);
        self.inner.waker.wake();
    }
Abort the `Abortable` stream/future associated with this handle.

Notifies the Abortable task associated with this handle that it
should abort. Note that if the task is currently being polled on
another thread, it will not immediately stop running. Instead, it will
continue to run until its poll method returns.
futures-util/src/abortable.rs