package
Version:
v1.1.0
Opens a new window with list of versions in this module.
Published: Mar 7, 2020
License: MPL-2.0
Opens a new window with license information.
Imports: 7
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
Mux is an event dispatcher with buffer
New creates a Mux with config
func (m *Mux) BufferSize() int
BufferSize returns the size of the buffer
Push the event into queue
func (m *Mux) Subscribe(s muxSink)
Subscribe adds a sink to the Mux
func (m *Mux) TryFlushQueue()
TryFlushQueue flush the queue if there's something in it
Source Files
¶
Click to show internal directories.
Click to hide internal directories.