This Week's Trending Top

This Month's Trending Top

This Year's Trending Top

rm-rf-etc
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
ryanzidago
What’s the canonical way of implementing an editable tabular data / grid / table in Phoenix LiveView? Think of a spreadsheet but only wi...
New
bvobart
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
apoorv-2204
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
tduccuong
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 Top

biera
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
dimitarvp
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
sezaru
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
j4p3
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
lud
Hello, Is there an idiomatic way to write greedy streams in elixir? Given this example: 1..1000 |> Stream.map(&computation_1/1)...
New
m_tofi
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
polypush135
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
Zsolt
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
almir-neto
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
Pistrie
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
tim.jarratt
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
DaAnalyst
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
dmitriid
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
dli
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
ValtteriL
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 Top

tanweerdev
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
Fl4m3Ph03n1x
Background PS: the following situation describes an hypothetical scenario, where I own a company that sells things to customers. I have ...
New
frumos
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
rrrr
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
Palindrome
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
nallwhy
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
tangui
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
sandorbedo
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
raigons
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
laurazard
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
blset
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
vishal-h
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
cblavier
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
emre
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
grufino
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
  • Follow
  • Join
  • Shape
the conversation

Latest on Elixir Forum

Elixir Forum

Similar Portals

    None added yet

We're in Beta

About us Mission Statement