pubsub

package

v2.11.0 Latest Latest Go to latest Published: Jun 23, 2026 License: MIT Imports: 1 Imported by: 7

Details

This section is empty.

This section is empty.

This section is empty.

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

func (me *PubSub[T]) Close()

func (me *PubSub[T]) NumSubs() int

NumSubs returns the number of active subscribers.

func (me *PubSub[T]) Publish(v T)

func (me *PubSub[T]) Subscribe() (ret *Subscription[T])

type Subscription[T any] struct {
	Values chan T
	// contains filtered or unexported fields
}

func (me *Subscription[T]) Close()