Latest #stream Threads 
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(...
New
For a list of integers, I can simply write a typespec like this:
@type foo() :: [integer()] # or list(integer())
But what about a Strea...
New
I saw that Ecto repo have the function Repo.stream, but I dont know what the steps happens when a trigger the Stream.run. A query like SE...
New
Hello,
I have this example where I would like a stream transformation to return the whole input list up to the third atom, included.
in...
New
How to make Task.async_stream return results as they are ready?
I have the following code:
defmodule Demo do
def run do
child =
...
New
Hello,
Is there an idiomatic way to write greedy streams in elixir?
Given this example:
1..1000
|> Stream.map(&computation_1/1)...
New
I’m trying to parse contents of a file in zip file. My idea is to use Unzip to stream contents (the unpacked file might be too large for ...
New
Hey everyone,
I have a GenStage producer that receives real-time events from a 3rd party websocket API and produces GenStage events. I w...
New
I am using Finch.stream to fetch a large CSV file from a server, but neither the ‘done’ state nor the ‘error’ state is being triggered wh...
New
Hey all. I’ve been working on a system lately that needs to ingest 10s of thousands to millions of rows from a data lake in order to do s...
New
This Week's Trending
This Month's Trending
This Year's Trending
I’m using WebSockex and Finch for a streaming client, and I want to emit every incoming message using an Elixir Stream, but how do I do t...
New
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(...
New
Last Three Year's Trending
I need to reduce enumerable collection to single value. Enum.reduce_while seems to be a perfect fit. However, in my case it’s expensive /...
New
Packmatic generates Zip Streams by aggregating File or URL Sources.
Hex / GitHub
By using a Stream, the caller can compose it within th...
New
Heya.
I am inviting you to copy-paste the module below and add your own functions and measure them, or simply give other ideas about how...
New
In my system, I have two tables, A and B where A has a foreign key to B.
I also have a processing step that will link a row in table A w...
New
When streaming input from a file of unknown size, formatted as a single line of comma-separated values, what’s the best way to operate on...
New
I’m tinkering around the idea of processing redis-stream messages in Elixir and this is one solution.
off_broadway_redis_stream is a red...
New
I am using Finch.stream to fetch a large CSV file from a server, but neither the ‘done’ state nor the ‘error’ state is being triggered wh...
New
I’m looking to learn the File module and was trying to think of a pet project for doing so.
I have a huge dir full of mp3 files that I w...
New
Hello,
Is there an idiomatic way to write greedy streams in elixir?
Given this example:
1..1000
|> Stream.map(&computation_1/1)...
New
Is there a library for transforming images using streams? Specifically I would like to resize and save images as webp. I’m using the imag...
New
I’m reading the documentation page, but it’s not landing. A stream basically defines how you want to go over the collection, without actu...
New
Hey all. I’ve been working on a system lately that needs to ingest 10s of thousands to millions of rows from a data lake in order to do s...
New
I saw that Ecto repo have the function Repo.stream, but I dont know what the steps happens when a trigger the Stream.run. A query like SE...
New
Hey everyone,
I have a GenStage producer that receives real-time events from a 3rd party websocket API and produces GenStage events. I w...
New
I’m trying to parse contents of a file in zip file. My idea is to use Unzip to stream contents (the unpacked file might be too large for ...
New
Trending Over Three Years
When request hangs control gained back is not printed(when I try to upload files bigger than 20 mb) But I see below error in my console
...
New
Hello,
I have a text file which has lines with new line separation “\n”
I need to stream this file by lines so I can apply my own funct...
New
Background
PS: the following situation describes an hypothetical scenario, where I own a company that sells things to customers.
I have ...
New
What is Elixir way to “merge” / “map” two sparse maps onto one? I want to apply some function on both or single value from these maps. By...
New
Hi there,
I’ve got the following function to read from a CSV file and insert the data into the address table of my database.
def proc...
New
I need to read very large data and write that to csv file.
I want to get last datum of the data after writing.
file = File.open!(file_p...
New
I want to stream data from a file to JSON lines into an downstream system (ELK). To do that, ideally, I can use Tesla whose put/4 functio...
New
Hi!
Some of you may have read the RabbitMQ announcement of Streams.
To quote the announcement:
A RabbitMQ stream models an append-onl...
New
Hi,
I use Task.async_stream to execute tasks on an extremely long stream of elements. Basically I use it as a pmap, except that I don’t...
New
Hi there.
For a matter of studying and practice reasons I have the following problem:
Given I have a log txt file (usually large, so th...
New
Hi all,
This is my first post in this forum, and although I did look, please forgive me if it’s a duplicate (or something very simple, I...
New
Let’s say we’ve a stream S1 that generates a random number between 1…100.
There is also another stream S2 that also generates a random n...
New
Hi all,
I am new to Elixir and are using this lib https://github.com/ankhers/mongodb to work with MongoDB. The doc says it has “Streamin...
New
Hi there,
I’m doing some computation on loads of Postgres data and I’m in the situation where I have two streams of data (Repo.stream/2)...
New
Hello there,
I have 3 streams, each streaming data from different sources. I want to merge these streams as well as run them in parallel...
New
Latest on Elixir Forum
Get money off!
The Pragmatic Bookshelf
35% off any eBook
Manning Publications
45% off any item
ElixirCasts
10% off for life
The Pragmatic Studio
20% off any course
AppSignal
10% off for 12 months
Honeybadger
10% off for 12 months
Simply use coupon code "devtalk.com" or "elixirforum" at checkout!
Filter by Type:
Popular Tags
- #ecto
- #liveview
- #troubleshooting
- #learning-elixir
- #deployment
- #erlang
- #testing
- #genserver
- #mix
- #absinthe
- #ash-questions
- #remote-other
- #otp
- #plug
- #how-to-question
- #macros
- #postgres
- #channels
- #exunit
- #discussion
- #javascript
- #elixirconf
- #library
- #oban-questions
- #dialyzer
- #docker
- #onsite
- #authentication
- #podcasts
- #full-time-contract
- #umbrella
- #code-sync
- #ecto-query
- #phoenix_html
- #iex
- #graphql
- #genstage
- #elixir-ls
- #nerves-questions
- #podcasts-by-brainlid
- #supervisor
- #websockets
- #distillery
- #advent-of-code
- #blog-post
- #livebook-questions
- #processes
- #forms
- #api
- #metaprogramming
Forums
Our Sponsors
Build Elixir applications with speed and confidence.
Supporting innovation across the BEAM ecosystem.
We build reliable cloud platforms for business-critical systems.
Catch errors, track performance, monitor hosts and more.
Producing high quality Elixir screencasts since 2017.
Enabling companies to succeed by building software people love.
The deployment platform built for Elixir: PaaS ease, VPS control.
Courses that'll move you from confusion to "Aha, now I get it!"