package
0.0.0-20241225174012-7a0820eadc6a
Repository: https://github.com/chtonad0000/golang.git
Documentation: pkg.go.dev

# README

pubsub

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

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

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

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

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

func NewPubSub() PubSub

# Functions

No description provided by the author

# Structs

No description provided by the author
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author

# Type aliases

MsgHandler is a callback function that processes messages delivered to subscribers.