Seeing this now after Add StreamData.repeatedly to pass in a function as your generator by aforward · Pull Request #104 · whatyouhide/stream_data · GitHub has been opened. Just wanted to mention here too that I also think that a generic way to convert streams to generators would be nice but there is a big limitation: generators are stateless while streams aren’t. Streams are enumerated in order and there is no way for generators to know at which index in the stream it’s at.
@ericmj also your solution can be even simpler as bind + constant is just map:
def repeatedly(fun) do
StreamData.map(StreamData.constant(nil), fn _ -> fun.() end)
end