The issue: I would like to consume stream one by one.But its not possible look below examples. iex(1)> s = 1..1000 |> Stream.map(& "Consumed #{&1}") #Stream<[enum: 1..1000, funs: [#Function<49.82544474/1 in Stream.map/2>]]> iex(2)> s |> Enum.take(1) ["Consumed 1"] iex(3)> s |> Enum.take(1) ["Consu…

[image] apoorv-2204: Expectations: When I do Enum.take(1) , I expect it to consume one element, and When I do I expect it to return the next element. That’s not what should happen. Elixir doesn’t differenciate “streams” – lazily producing enumerables – from other enumerables like lists or map…

But the issue is I am passing ref here and there b/w functions I(.e in genserver handle info )and want to resume it where i left it.

That’s not how the Enumerable abstraction works though. I don’t know what you’re streaming there, but I’d consider using other apis instead of an enumerable.

I am streaming here a S3 object, or a file. And I am sending it to 3310 port to clamd for scanning

Start a GenServer to handle the streaming logic. Initialize GenServer state with an offset (e.g., 0) in init/1. store the stream object in an ETS table. defmodule StreamServer do use GenServer @ets_table :stream_storage def start_link(_opts \\ []) do GenServer.start_link(__MODULE__, 0…

Elixir Programming Language Forum

Is Stateful Stream possible?

Questions & Help Questions

krasenyp August 8, 2025, 5:14am 7

Or, use the process state as storage.