streaming

Documentation

Index

• Constants
• type Mux
  • func (m *Mux) Publish(event string, data any) error
  • func (m *Mux) Subscribe() *Subscription
• type Payload
• type Subscription
  • func (s *Subscription) Cancel()

Constants

const MuxContextKey = muxContextKey("")

Types

type Mux

type Mux struct {
	// contains filtered or unexported fields
}

func (*Mux) Publish

func (m *Mux) Publish(event string, data any) error

func (*Mux) Subscribe

func (m *Mux) Subscribe() *Subscription

type Payload

type Payload struct {
	Event string
	Data  any
}

type Subscription

type Subscription struct {

	// The channel to which events are received.
	C <-chan Payload
	// contains filtered or unexported fields
}

func (*Subscription) Cancel

func (s *Subscription) Cancel()