Latest #stream Threads 
Hi,
I am running into CubDB timeout and not sure where to improve:
CubDB.select(ref, [min_key: {:tests, 1}, max_key: {:tests, 5}, min_k...
New
Stream.peek and Stream.pop
I find Stream API limited and I often have to introduce workarounds for things like taking values from enumera...
New
What’s the canonical way of implementing an editable tabular data / grid / table in Phoenix LiveView?
Think of a spreadsheet but only wi...
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
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
Hi all
My go to pattern for handling data recently has been: have a Delete button on item. When user clicks the button, overlay the item...
New
This Week's Trending
This Month's Trending
This Year's Trending
Packmatic generates Zip Streams by aggregating File or URL Sources.
Hex / GitHub
By using a Stream, the caller can compose it within th...
New
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
What’s the canonical way of implementing an editable tabular data / grid / table in Phoenix LiveView?
Think of a spreadsheet but only wi...
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
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
Stream.peek and Stream.pop
I find Stream API limited and I often have to introduce workarounds for things like taking values from enumera...
New
Hi,
I am running into CubDB timeout and not sure where to improve:
CubDB.select(ref, [min_key: {:tests, 1}, max_key: {:tests, 5}, min_k...
New
Last Three Year's Trending
After playing around with stream/4 and reading up on all the new LV features, I was tasked at work with making an infinite scroll page. I...
New
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
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
Hello,
Is there an idiomatic way to write greedy streams in elixir?
Given this example:
1..1000
|> Stream.map(&computation_1/1)...
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
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 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
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
So, before I allocate the time required to build a demo app reproducing these two, is there someone else who encountered the two bugs (an...
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
EDIT: Feel free to read the discussion, but the issue was reading the Benchee results wrong. It tracks allocated memory throughout the be...
New
Background
PS: the following situation describes an hypothetical scenario, where I own a company that sells things to customers.
I have ...
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
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
When i use List.flatten() it would flatten a deep list with every nested .
iex> list = [[],["ant",["hello","hi",[[[]]]], "bat"], ["ca...
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
Hello,
Having a Task.supervisor under a phoenix app, and using it with Task.supervisor.async_no_link
is there a way to stop the stream ...
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
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
- #library
- #erlang
- #testing
- #genserver
- #mix
- #absinthe
- #remote-other
- #otp
- #plug
- #how-to-question
- #macros
- #postgres
- #channels
- #exunit
- #elixirconf
- #discussion
- #javascript
- #podcasts
- #code-sync
- #onsite
- #dialyzer
- #docker
- #authentication
- #umbrella
- #full-time-contract
- #podcasts-by-brainlid
- #ecto-query
- #elixir-ls
- #phoenix_html
- #iex
- #blog-post
- #graphql
- #genstage
- #ai
- #websockets
- #supervisor
- #advent-of-code
- #distillery
- #api
- #processes
- #forms
- #metaprogramming
- #security
- #performance
- #hex
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.
Develop your skills with books, videos, and courses.
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!"