···

       
118
       
118
       
 
       
 * for the JS Iterable protocol.

     

       
119
       
119
       
 
       
 */

     

       
120
       
120
       
 
       
export function fromIterable<T>(iterable: Iterable<T> | AsyncIterable<T>): Source<T> {

     

       
121
       
121
       
-
       
  if (iterable[Symbol.asyncIterator]) return fromAsyncIterable(iterable as AsyncIterable<T>);

     

       
121
       
121
       
+
       
  if (iterable[asyncIteratorSymbol()]) return fromAsyncIterable(iterable as AsyncIterable<T>);

     

       
122
       
122
       
 
       
  return sink => {

     

       
123
       
123
       
 
       
    const iterator = iterable[Symbol.iterator]();

     

       
124
       
124
       
 
       
    let ended = false;