subscribe

package

v1.0.1 Latest Latest Go to latest Published: Nov 30, 2018 License: LGPL-3.0 Imports: 4 Imported by: 2

Details

View Source

const (
	AddNewPeer = "addNewPeer"
	DeletePeer = "deletePeer"
)

View Source

var (
	ErrChType       = errors.New("error of channel type")
	ErrNotExistName = errors.New("not exist special subscription")
)

func Send(name string, value interface{})

func Sub(name string, ch interface{})

func UnSub(name string, ch interface{})

type CaseListItem struct {
	// contains filtered or unexported fields
}

type CentralRouteSub struct {
	// contains filtered or unexported fields
}

func NewCentralRouteSub() *CentralRouteSub

type Feed struct {
	// contains filtered or unexported fields
}

func (f *Feed) Send(value interface{}) (nsent int)

func (f *Feed) Subscribe(channel interface{}) Subscription

type Subscription interface {
	Err() <-chan error
	Unsubscribe()
}