tool

package

v1.5.0 Latest Latest Go to latest Published: Apr 6, 2025 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Publisher[T any] struct {
	// contains filtered or unexported fields
}

func NewPublisher[T any]() *Publisher[T]

func (p *Publisher[T]) GetSubscriberCount() int

func (p *Publisher[T]) Publish(event T)

func (p *Publisher[T]) Subscribe(subscriber Subscriber[T])

func (p *Publisher[T]) Unsubscribe(subscriberID string)

type Subscriber[T any] interface {
	OnEvent(event T)
	GetID() string
}