search

ReactiveX / RxGo

Reactive Extensions for the Go language.
MIT License
4.93k stars 336 forks source link

Real-World Example in doc #410

Open HaveF opened 2 months ago

HaveF commented 2 months ago

Hi, There, Thanks for this repo,

I find I can't make the Real-World Example in Doc works as expected, even I add lots of fmt.Printf

https://go.dev/play/p/imrQXHVVR9T

the program should get id2 and id3 processed. But I only get ID2 processed. Did I screw up something?

Processed Customer: {ID:2 Name:Jane LastName:Smith Age:25 TaxNumber:TAX2}
HaveF commented 2 months ago

Maybe I find the spot, but don't know how to fix it. If I comment the line rxgo.WithPool(3), // Increase concurrency, the result is fine.