Hi guys! I`m trying to make 5 requests at once and here is my code: require "http/client" channel = Channel(String).new list = %w[ https://www.akitaonrails.com/ https://citizen428.net/ https://crystal-lang.org/ https://www.akitaonrails.com/ https://citizen428.net/ https://crystal-lang…

The gist of it is you only get a single response because you only ever call channel.receive once. If you want it to print all of them, you need to call it the same amount of times as there were requests. E.g. list.size.times do puts channel.receive end

Hi, @Blacksmoke16 , instead of use list.size.times ..., is there a way to use loop or while instead?

You could do it a number of ways yes, but the gist of it is you need to do it in a way where you call receive the same amount of times as you spawned fibers. Otherwise if you do it less you won’t get all the data back, but if you do it more, it’ll block waiting for data that’ll never come.

Yes, i understood what you means, but my concern is another issue, following is a example. ch = Channel(Int32).new [1, 2, 3].each do |i| spawn do # => NOTICE: spawn 3 fiber here. ch.send i end end # We have to encode a 3.times or ???.size.times.here 3.times do |i| p ch.receive end Abov…

[image] zw963: i want to use loop/where instead. You would have to keep track of how many iterations you went thru and break out of the loop once you reached the amount of fibers you spawned. I.e. essentially what .size.times does. Is there a reason using that isn’t sufficient for your use c…

Hi, this solution seems to work only under certain conditions. For simplicity, see the following example: following code always work def prime?(n) (2...n).all? { |i| n % i != 0 } end def primes(n) (3..n).select { |x| prime?(x) } end ch = Channel(Int32).new terminate = Channel(Nil).new done …

@Blacksmoke16 , i test on one of my recent created shards, it seem like not works as expected too, please check. Test close channel. zw963:master ← zw963:test_close_channel opened 05:59PM - 17 Sep 22 UTC (UTC) …

I’m pretty sure it’s expected. Remember fibers do not immediately execute when they’re spawned. So in this example when you have the sleep 1, you spawn the 4 prime fibers, and another fiber with the loop + select. The terminate channel is then closed. Finally you call receive? on the done channel wh…

[image] Blacksmoke16: hits the sleep, execution switches to one of the prime fibers, hits the sleep, execution switches to the loop + select fiber, no value was sent to the ch channel due to the sleep, Yes, But, this case seems like inevitable? i add sleep 1 just for simulate it. as you see…

How to send http requests with Channels?

Help & Support

dunaevv June 15, 2022, 10:39pm 3

Y a my best friend ^_^
Thanks!)))))

Topic		Replies	Views
Fibers, channels and blocking Help & Support	3	1579	July 8, 2020
Is this the only way to terminate? Help & Support	13	420	August 28, 2024
Fibers: different code results with the Guide Help & Support	6	837	November 28, 2019
Distinction between channels and fibers Help & Support	3	603	October 2, 2019
How to wait a message on multiple channels? Help & Support	10	351	November 22, 2024

How to send http requests with Channels?

Related topics