callback

package

v0.0.5 Latest Latest Go to latest Published: Oct 12, 2022 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(logger logging.Logger) *Callback

func (c *Callback) Cancel(id int) error

Cancel removes a callback based on an callback ID

func (c *Callback) On(method string, f handlerFunc) int

On adds a new callback based on an ethrpc method and returns the associated callback ID

func (c *Callback) Register(id uint64, method string)

Register keeps track of the ethrpc requests with ethrpc ID to ethrpc method name mapping. It must be called before callback.Run()

func (c *Callback) Run(resp *Response)

Run, with the ID from the ethrpc response, finds the registered method name, and executes all callbacks associated with the method.

type Response struct {
	Body *ethrpc.JsonrpcMessage
	IP   string
}