streaming

package
v0.0.0-...-3750746 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 22, 2024 License: BSD-3-Clause Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source
const MuxContextKey = muxContextKey("")

Variables

This section is empty.

Functions

This section is empty.

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL