shad-go

History

verytable daa02c8abf Resolve "upgrage to 1.17"		2022-02-10 22:06:57 +00:00
..
my_pubsub.go	Resolve "upgrage to 1.17"	2022-02-10 22:06:57 +00:00
pubsub.go	Resolve "upgrage to 1.17"	2022-02-10 22:06:57 +00:00
pubsub_example_test.go	Add pubsub task	2020-03-26 17:42:29 +00:00
pubsub_test.go	Fix linter	2020-04-02 22:25:04 +03:00
README.md	Update README	2021-04-01 18:05:31 +03:00

pubsub

В этой задаче нужно написать простую шину событий работающую по принципу pub/sub.

В файле pubsub.go заданы интерфейсы PubSub/Subscription с подробным описанием всех методов.

Требования к системе:

На один топик может подписываться (и отписываться) множество подписчиков.
FIFO для сообщений, вы не должны терять их порядок.
Один медленный подписчик не должен тормозить остальных.
Метод Close должен уважать переданный контекст, так если он отменен - выходим сразу, бегущие хендлеры оставляем бежать.
Если будут использоваться горутины - они не должны течь :)

Нужно написать реализацию и конструктор (см. my_pubsub.go):

func NewPubSub() PubSub