eventbus

README

DEPRECATION NOTICE

This package has moved into go-libp2p as a sub-package, github.com/libp2p/go-libp2p/p2p/host/eventbus.

go-eventbus

Simple and fast eventbus for type-based local event delivery.

Install

go get github.com/libp2p/go-eventbus

Usage

Check out the GoDocs.

License

Dual-licensed under MIT and ASLv2, by way of the Permissive License Stack.

Documentation

Overview

Deprecated: This package has moved into go-libp2p as a sub-package: github.com/libp2p/go-libp2p/p2p/host/eventbus.

Index

• func BufSize(n int) func(interface{}) error
• func NewBus() event.Bus
• func Stateful(s interface{}) error

Functions

func BufSize

func BufSize(n int) func(interface{}) error

Deprecated: Use github.com/libp2p/go-libp2p/p2p/host/eventbus.BufSize instead.

func NewBus

func NewBus() event.Bus

Deprecated: Use github.com/libp2p/go-libp2p/p2p/host/eventbus.NewBus instead.

func Stateful

func Stateful(s interface{}) error

Stateful is an Emitter option which makes the eventbus channel 'remember' last event sent, and when a new subscriber joins the bus, the remembered event is immediately sent to the subscription channel.

This allows to provide state tracking for dynamic systems, and/or allows new subscribers to verify that there are Emitters on the channel Deprecated: Use github.com/libp2p/go-libp2p/p2p/host/eventbus.Stateful instead.