Look at how zip is implemented. We don't expose it directly because any suspended stream/enumerable needs to be eventually terminated, so it is easy to mess things up, but if we encapsulate it in a process, we can guarantee we do so. You can also look at GenStage stream integration.
*José Valimhttps://dashbit.co/ <https://dashbit.co/>* On Fri, Feb 7, 2025 at 12:27 PM Łukasz Niemier <luk...@niemier.pl> wrote: > > That sounds reasonable and I would be curious to see how a proof of > concept of this would look like in practice. Given we can suspend streams, > we should be able to consume/emit items one by one. This is similar how to > GenStage converts streams into stages. > > Can we? I haven't seen such functionality in `Stream` module. > > -- > > Łukasz Niemier > luk...@niemier.pl > > -- > 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 elixir-lang-core+unsubscr...@googlegroups.com. > To view this discussion visit > https://groups.google.com/d/msgid/elixir-lang-core/6D3F3D69-61DF-40BF-8ABB-2D4C2B928D63%40niemier.pl > . > -- 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 elixir-lang-core+unsubscr...@googlegroups.com. To view this discussion visit https://groups.google.com/d/msgid/elixir-lang-core/CAGnRm4%2BUGrbmy3txA5vZ9U%3D2%2BgA_6NdKnTFsAsSSs%3DJjCKNmLw%40mail.gmail.com.
