pubsub

package

v1.0.0 Latest Latest Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

A generic pubsub system built with go channels. Used to communicate different pieces of data across the app. Latest block, stream txs, etc.

This section is empty.

This section is empty.

This section is empty.

type Pubsub[Message any] struct {
	// contains filtered or unexported fields
}

func NewPubsub[Message any]() *Pubsub[Message]

func (ps *Pubsub[Message]) Publish(ctx context.Context, topic string, msg Message)

Publish sends a message to all subscribers of the specified topic

func (ps *Pubsub[Message]) Subscribe(topic string, bufferSizes ...int) chan Message

Subscribe subscribes to a specific topic and returns a channel to receive messages.

func (ps *Pubsub[Message]) Unsubscribe(topic string, ch chan Message)

Unsubscribe removes a subscriber from a topic and closes the channel.