I have a Flow setup that does a port scan on localhost to catch anything I currently have running:

    range
    |> Flow.from_enumerable()
    |> Flow.partition()
    |> Flow.map(fn port ->
      %URI{
        host: host,
        path: "/status",
        port: port,
        scheme: "http"
      }
      |> URI.to_string()
      |> IO.inspect() # <-- only here for troubleshooting, issue persists without it
      |> Req.get(retry: false)
      |> assign(port)
    end)
    |> Flow.reject(fn response -> Enum.empty?(response) end)
    ...

Whether or not I use Flow.partition() doesn’t seem to have an effect on it, but the IO.inspect() seems to be printing out 24 items at a time with a delay of about one second between printing. Putting Flow.from_enumerable(max_demand: 1) (something I saw on StackOverflow) doesn’t do anything to speed it up either.

When I run this same code on Ubuntu, the process completes in less than half a second. Is this an issue with how Windows allocates processes? Has anyone else experienced this with Flow? Or is this just poorly written code that Flow doesn’t know what to do with?