from_iterable was over-consuming during stop

Author: dwskoog

streamz/sources.py

@@ -786,6 +786,8 @@ async def run(self):
             if self.stopped:
                 break
             await asyncio.gather(*self._emit(x))
+            if self.stopped:
+                break
         self.stopped = True