mpmc

Documentation

Index

• type Consumer
  • func (c *Consumer[T]) Receive() (*T, error)
• type MPMC
  • func NewMPMC[T any](capacity uint64) *MPMC[T]
  • func (mpmc *MPMC[T]) Send(value T)
  • func (mpmc *MPMC[T]) Subscribe() *Consumer[T]

Types

type Consumer

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

func (*Consumer[T]) Receive

func (c *Consumer[T]) Receive() (*T, error)

type MPMC

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

func NewMPMC

func NewMPMC[T any](capacity uint64) *MPMC[T]

func (*MPMC[T]) Send

func (mpmc *MPMC[T]) Send(value T)

func (*MPMC[T]) Subscribe

func (mpmc *MPMC[T]) Subscribe() *Consumer[T]