search

liftbridge-io / go-liftbridge

Go client for Liftbridge. https://github.com/liftbridge-io/liftbridge
Apache License 2.0
67 stars 18 forks source link

Subscribe hangs #62

Closed ehsannm closed 4 years ago

ehsannm commented 4 years ago

If we subscribe with offsetID > stream.lastOffsetID, the liftbridge.Handler is called with 'err' argument set to EOF. However I thinks it must wait until new message arrives. This should the caller to handle timeout. This way we improve the need for checking for subscribe on fast intervals by handling a longer timeout.

tylertreat commented 4 years ago

I'm not sure I understand. Can you provide the configuration and steps to reproduce the behavior you're seeing?

ehsannm commented 4 years ago

nothing i was using the context with timeout on Subscribe which was the problem. I close the issue