Do not lock inner twice. Fixes bug in osx futures 0.1.1 update.
This commit is contained in:
parent
869af718a2
commit
f71a95cd0e
|
@ -114,7 +114,7 @@ impl Stream for SamplesStream {
|
|||
let current_callback = match inner.current_callback.take() {
|
||||
Some(c) => c,
|
||||
None => {
|
||||
self.inner.lock().unwrap().scheduled_task = Some(task::park());
|
||||
inner.scheduled_task = Some(task::park());
|
||||
return Ok(Async::NotReady);
|
||||
}
|
||||
};
|
||||
|
|
Loading…
Reference in New Issue