timpalpant / go-tradier Goto Github PK

Is there a way to properly resubscribe. I am getting duplicate messages if a new connection is made. Is there a way to drop the previous connection?

I'm testing the streamer against mine (which is written in ruby with eventmachine, has been proven to work well for two years) and I noticed delays. I started digging into it more comparing every single trade for a specific low volume symbol, and noticed trade events are being dropped. I am streaming 150 symbols, so I suspect something must not be right related to goroutines. I used https://github.com/bcicen/grmon to monitor goroutines, and sure enough I didn't see as many goroutines as I'd expect for the streamer to keep up with the fast and furious pace of trades coming in. I'm a go newbie so I'm still digging around about this, but I thought to let you know.

Shouldn't a new goroutine be spawned for every incoming line? otherwise the streamer can't keep up.