fromTask<A> function

Stream<A> fromTask<A>(
  1. Task<A> task
)

Implementation

Stream<A> fromTask<A>(T.Task<A> task) =>
    FromCallableStream(() => task(), reusable: true).asBroadcastStream();