The highest tagged major version is v3.

event

package

v1.0.86 Latest Latest Go to latest Published: Dec 13, 2019 License: BSD-2-Clause Imports: 4 Imported by: 27

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/djthorpe/gopi

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Merger
type Publisher
type Signal
type TaskFunc
type Tasks
- func (this *Tasks) Close() error
- func (this *Tasks) Start(funcs ...TaskFunc)

Constants ¶

This section is empty.

Variables ¶

View Source

var DONE = Signal{}

View Source

var (
	NullEvent = &nullEvent{}
)

Functions ¶

This section is empty.

Types ¶

type Merger ¶

type Merger struct {
	sync.Mutex
	Publisher
	// contains filtered or unexported fields
}

func (*Merger) Close ¶

func (this *Merger) Close()

func (*Merger) Merge ¶

func (this *Merger) Merge(publisher gopi.Publisher)

func (*Merger) Unmerge ¶

func (this *Merger) Unmerge(publisher gopi.Publisher)

type Publisher ¶

type Publisher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Publisher) Close ¶

func (this *Publisher) Close()

Close will unsubscribe all remaining channels

func (*Publisher) Emit ¶

func (this *Publisher) Emit(evt gopi.Event)

Emit an event onto all subscriber channels, this method will block if the subscribers are not processing incoming events

func (this *Publisher) Subscribe() <-chan gopi.Event

Subscribe returns a new channel on which emitting events can occur

func (*Publisher) Unsubscribe ¶

func (this *Publisher) Unsubscribe(subscriber <-chan gopi.Event)

Unsubscribe closes a channel and removes it from the list of channels which emitting can happen on

type Signal ¶ added in v1.0.20

type Signal struct{}

type TaskFunc ¶ added in v1.0.20

type TaskFunc func(start chan<- Signal, stop <-chan Signal) error

type Tasks ¶ added in v1.0.20

type Tasks struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func (*Tasks) Close ¶ added in v1.0.20

func (this *Tasks) Close() error

Close sends done signals to each go routine and will return any error from the tasks. Each go routine may end before the 'stop' signal is returned...

func (*Tasks) Start ¶ added in v1.0.20

func (this *Tasks) Start(funcs ...TaskFunc)

Start tasks in the background and waits for all "start" signals to be returned before unblocking

Source Files ¶

View all Source files

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