Hello 👋, Firstly, I would like to thank <a class="user-mention notr

How to stop subscriber goroutine when publisher goroutine is canceled ? about machine HOT 1 CLOSED

vikramarsid commented on September 28, 2024

How to stop subscriber goroutine when publisher goroutine is canceled ?

from machine.

Comments (1)

autom8ter commented on September 28, 2024

Hello, I have added SubscribeUntil(), SubscribeWhile(), & SubscribeN() methods to the routine interface that should let you break the subscription!

        // SubscribeN subscribes to the given channel until it receives N messages or its context is cancelled
	SubscribeN(channel string, n int, handler func(msg interface{})) error
	// SubscribeUntil subscribes to the given channel until the decider returns false for the first time. The subscription breaks when the routine's context is cancelled or the decider returns false.
	SubscribeUntil(channel string, decider func() bool, handler func(msg interface{})) error
	// SubscribeWhile subscribes to the given channel while the decider returns true. The subscription breaks when the routine's context is cancelled.
	SubscribeWhile(channel string, decider func() bool, handler func(msg interface{})) error

Please see the updated README for an example and let me know if this will work for you.

from machine.

Recommend Projects