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
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
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
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
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
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
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
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
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
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,
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
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
Hi!
I am currently porting our old python data pipeline to elixir, and after implementing it more of less the same, I can’t make it run ...
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:
Sub Categories:
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







