import { ReadableApp } from "@scramjet/types" ; const exp = param _stream returns function ( _stream ) { const data = this . initialState ; let x = data ?. x || 0 ; return async function * ( ) { while ( x ++ ) { yield { a : x } ; await new Promise ( res => setTimeout ( res , 1000 ) ) ; } } ; } ; export = exp ;