> sequence > |> String.to_charlist > |> Enum.chunk(l, 1) > |> Flow.from_enumerable > |> Flow.map(fn e -> Enum.chunk(e, k, 1) end) >
Do you call partition at some point in your flow? Otherwise it won't exploit parallelism if you have only one source. Also, if you need to chunk before you partition, you can chunk before calling from_enumerable: sequence |> String.to_charlist |> Stream.chunk(e, k, 1) |> Flow.from_enumerable |> ... I think it will be easy to add chunking to Flow because we can delegate to Stream but I just want to make sure I fully understand your use case and where parallelism is being introduced. -- You received this message because you are subscribed to the Google Groups "elixir-lang-core" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To view this discussion on the web visit https://groups.google.com/d/msgid/elixir-lang-core/CAGnRm4KpD-tf5p5sAS2nwZusd0reKdti-zL8-wzf%3DHjD8p%3D5qQ%40mail.gmail.com. For more options, visit https://groups.google.com/d/optout.
