Task.Supervisor.async_stream_nolink

You're seeing just the function async_stream_nolink, go back to Task.Supervisor module for more information.
Link to this function

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.

Link to this function

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.