Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stream

package module

Go to main page

Versions in this module

v0

v0.1.2

Aug 5, 2026

v0.1.1

Jul 5, 2026

v0.1.0

Jul 3, 2026

Changes in this version

+ type CatchupListener interface

+ CaughtUp func()

+ type Consumer interface

+ Consumes func() []Subject

+ type Message interface

+ Body func(dst interface{}) error

+ Meta func(dst interface{}) error

+ RawBody func() interface{}

+ RawMeta func() interface{}

+ Sequence func() uint64

+ Subject func() Subject

+ Time func() time.Time

+ type MessageFunc func(Subject) MutableMessage

+ type MessageHandler interface

+ HandleMessage func(Message) error

+ type MessageHandlerFunc func(Message) error

+ func (f MessageHandlerFunc) HandleMessage(msg Message) error

+ type MutableMessage interface

+ SetBody func(interface{}) error

+ SetMeta func(interface{}) error

+ SetSubject func(Subject)

+ SetTime func(time.Time) error

+ type Producer interface

+ Produces func() []Subject

+ type Publisher interface

+ MessageFunc func() MessageFunc

+ Publish func(msg Message) error

+ type PublisherFunc func(Message) error

+ func (f PublisherFunc) MessageFunc() MessageFunc

+ func (f PublisherFunc) Publish(msg Message) error

+ type Stream interface

+ Close func() error

+ type Subject interface

+ Domain func() string

+ Match func(string) bool

+ Parts func() []string

+ Subject func() string

+ Type func() string

+ type Subscriber interface

+ Subscribe func(subjects []Subject, h MessageHandler) (Subscription, error)

+ type Subscription interface

+ Close func() error