core: v2ray.com/core/common/signal/pubsub Index | Files

package pubsub

import "v2ray.com/core/common/signal/pubsub"

Index

Package Files

pubsub.go

type Service Uses

❖
type Service struct {
    sync.RWMutex
    // contains filtered or unexported fields
}

func NewService Uses

❖
func NewService() *Service

func (*Service) Cleanup Uses

❖
func (s *Service) Cleanup() error

Cleanup cleans up internal caches of subscribers. Visible for testing only.

func (*Service) Publish Uses

❖
func (s *Service) Publish(name string, message interface{})

func (*Service) Subscribe Uses

❖
func (s *Service) Subscribe(name string) *Subscriber

type Subscriber Uses

❖
type Subscriber struct {
    // contains filtered or unexported fields
}

func (*Subscriber) Close Uses

❖
func (s *Subscriber) Close() error

func (*Subscriber) IsClosed Uses

❖
func (s *Subscriber) IsClosed() bool

func (*Subscriber) Wait Uses

❖
func (s *Subscriber) Wait() <-chan interface{}

Package pubsub imports 6 packages (graph) and is imported by 2 packages. Updated 2019-04-05. Refresh now. Tools for package owners.