|
|
@ -67,8 +67,6 @@ impl Command
|
|
|
|
/// Dispose of this `Command`, returning any `Response` that might've already been sent.
|
|
|
|
/// Dispose of this `Command`, returning any `Response` that might've already been sent.
|
|
|
|
#[inline] pub fn close(mut self) -> Option<Response>
|
|
|
|
#[inline] pub fn close(mut self) -> Option<Response>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
use oneshot::error::TryRecvError;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
self.resp.close();
|
|
|
|
self.resp.close();
|
|
|
|
self.resp.try_recv().ok().flatten()
|
|
|
|
self.resp.try_recv().ok().flatten()
|
|
|
|
}
|
|
|
|
}
|
|
|
|