code: def test_from_iterable():
      source = Source.from_iterable(range(3))
      L = source.sink_to_list()
      source.start()
      wait_for(lambda: L == [0, 1, 2], 0.1)
  
file_path: streamz/streamz/tests/test_sources.py
imports: import asyncio
  import sys
  from flaky import flaky
  import pytest
  from streamz import Source
  from streamz.utils_test import wait_for, await_for, gen_test
  import socket
label_desc: Use image node_id 7 for calling a global function with example usage: test_from_iterable() without return types