multichannel

Documentation

Index

• Variables
• type Topic
  • func NewTopic[T any](clone messaging.MessageCloneFunc[T], subChannelSize int) *Topic[T]
  • func NewTopicWithDefaults[T any]() *Topic[T]
  • func (t *Topic[T]) Publish(ctx context.Context, message T) (err error)
  • func (t *Topic[T]) Subscribe(_ context.Context) (stream messaging.Stream[T], err error)

Variables

var (
	ErrSendFailed = errors.New("send failed")
)

Types

type Topic

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

func NewTopic

func NewTopic[T any](clone messaging.MessageCloneFunc[T], subChannelSize int) *Topic[T]

NewTopic returns a new instance of messaging.Topic

func NewTopicWithDefaults

func NewTopicWithDefaults[T any]() *Topic[T]

func (*Topic[T]) Publish

func (t *Topic[T]) Publish(ctx context.Context, message T) (err error)

Publish sends a message to all subscribers of this topic in parallel All subscribers must be able to receive the message or this function will block

func (*Topic[T]) Subscribe

func (t *Topic[T]) Subscribe(_ context.Context) (stream messaging.Stream[T], err error)

Subscribe returns a channel that will receive messages published to this topic