From da8390ef7bed20bcf835e02977507eb5d0d3df5d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sebastian=20Dr=C3=B6ge?= <sebastian@centricular.com>
Date: Tue, 24 Apr 2018 12:32:03 +0300
Subject: [PATCH] threadshare: Update for tokio API changes

---
 gst-plugin-threadshare/src/iocontext.rs | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/gst-plugin-threadshare/src/iocontext.rs b/gst-plugin-threadshare/src/iocontext.rs
index b992f5a9..13c43041 100644
--- a/gst-plugin-threadshare/src/iocontext.rs
+++ b/gst-plugin-threadshare/src/iocontext.rs
@@ -134,8 +134,6 @@ impl IOContextRunner {
 
             ::tokio_reactor::with_default(&handle, &mut enter, |mut enter| {
                 ::tokio_timer::with_default(&timer_handle, &mut enter, |enter| loop {
-                    use tokio::executor::current_thread::Turn;
-
                     let now = time::Instant::now();
 
                     if self.shutdown.load(atomic::Ordering::SeqCst) > RUNNING {
@@ -150,10 +148,11 @@ impl IOContextRunner {
                     }
 
                     gst_trace!(CONTEXT_CAT, "Turning current thread '{}'", self.name);
-                    while let Turn(true) = current_thread
+                    while current_thread
                         .enter(enter)
                         .turn(Some(time::Duration::from_millis(0)))
                         .unwrap()
+                        .has_polled()
                     {}
                     gst_trace!(CONTEXT_CAT, "Turned current thread '{}'", self.name);