events

Documentation

Index

• type Events
  • func NewEvents() *Events
  • func (events *Events) Subscribe(address umi.Address, ch chan<- []byte)
  • func (events *Events) SubscribeTo(blockchain iBlockchain)
  • func (events *Events) SubscribeTo2(mempool iMempool)
  • func (events *Events) Unsubscribe(address umi.Address, ch chan<- []byte)
  • func (events *Events) Worker(ctx context.Context)

Types

type Events

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

func NewEvents

func NewEvents() *Events

func (*Events) Subscribe

func (events *Events) Subscribe(address umi.Address, ch chan<- []byte)

func (*Events) SubscribeTo

func (events *Events) SubscribeTo(blockchain iBlockchain)

func (*Events) SubscribeTo2

func (events *Events) SubscribeTo2(mempool iMempool)

func (*Events) Unsubscribe

func (events *Events) Unsubscribe(address umi.Address, ch chan<- []byte)

func (*Events) Worker

func (events *Events) Worker(ctx context.Context)