Task.Supervisor.async_stream_nolink
async_stream_nolink
, go back to Task.Supervisor module for more information.
async_stream_nolink(supervisor, enumerable, fun, options \\ [])
View Source (since 1.4.0)Specs
async_stream_nolink( Supervisor.supervisor(), Enumerable.t(), (term() -> term()), keyword() ) :: Enumerable.t()
Returns a stream that runs the given function
concurrently on each
element in enumerable
.
Each element in enumerable
is passed as argument to the given function fun
and processed by its own task. The tasks will be spawned under the given
supervisor
and will not be linked to the current process, similarly to async_nolink/2
.
See async_stream/6
for discussion and examples.
async_stream_nolink(supervisor, enumerable, module, function, args, options \\ [])
View Source (since 1.4.0)Specs
async_stream_nolink( Supervisor.supervisor(), Enumerable.t(), module(), atom(), [term()], keyword() ) :: Enumerable.t()
Returns a stream where the given function (module
and function
)
is mapped concurrently on each element in enumerable
.
Each element in enumerable
will be prepended to the given args
and processed
by its own task. The tasks will be spawned under the given supervisor
and
will not be linked to the current process, similarly to async_nolink/4
.
See async_stream/6
for discussion, options, and examples.