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 [email protected]. 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.
