fromReaderTask<ENV, A> function

ReaderStream<ENV, A> fromReaderTask<ENV, A>(ReaderTask<ENV, A> rt)

Implementation

ReaderStream<ENV, A> fromReaderTask<ENV, A>(RT.ReaderTask<ENV, A> rt) =>
    (env) => S.fromTask(rt(env));