pubsub

Documentation

Index

• type PubSub
  • func (me *PubSub[T]) Close()
  • func (me *PubSub[T]) Publish(v T)
  • func (me *PubSub[T]) Subscribe() (ret *Subscription[T])
• type Subscription
  • func (me *Subscription[T]) Close()

Types

type PubSub

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

func (*PubSub[T]) Close

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

func (*PubSub[T]) Publish

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

func (*PubSub[T]) Subscribe

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

type Subscription

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

func (*Subscription[T]) Close

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