Re: [elixir-core:6239] GenStage and Tweets. 1 producer, 3 consumers but only one consumer receives the tweets

[José Valim]

Thanks Alvise. However, next time please don't double post on both elixir-lang-core and elixirforum. :) We can continue this discussion there.

José Valim

www.plataformatec.com.br

Skype: jv.ptec

Founder and Director of R&D

On Tue, Aug 23, 2016 at 12:33 PM, Alvise Susmel <alv...@poeticoding.com> wrote:

Hi guys, 

I'm playing a bit with GenStage, after reading the blog post on elixir with a full case description, and watching the youtube Jose's speech. 

  _____________

  |                         |

  | Producer        |   <------> consumer 1

  | tweets stream  |    <------> consumer 2

  |____________ |   <-------> consumer 3

I'm playing with it using twitter streams. The producer reads the twitter streams, receiving all the tweets linked to the hashtag #rio2016, and pass them to the consumers.

in the gist there are app, producer, consumer and log output

https://gist.github.com/alvises/656cacf7b1962927b34f2708e52ebc6f 

I've started 3 consumers. Once a consumer receives a bunch of tweets from the producer, I put it to sleep for 10s to simulate the processing. The problem is that the other 2 consumers don't receive anything..

if I change the stream to a local big file, all the 3 consumers receive events...

Does anyone know why ?

Thanks

Alvise

--
You received this message because you are subscribed to the Google Groups "elixir-lang-core" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elixir-lang-core+unsubscribe@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/elixir-lang-core/01d40559-b800-4dab-b165-fc8e31a7eab4%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.