Method RunWithSocket

kernel.go:112–116

RunWithSocket invokes the `run` function after acquiring the `Socket.Lock` and releases the lock when done.

(run func(socket zmq4.Socket) error)

// RunWithSocket invokes the `run` function after acquiring the `Socket.Lock` and releases the lock when done.
func (s *Socket) RunWithSocket(run func(socket zmq4.Socket) error) error {
	s.Lock.Lock()
	defer s.Lock.Unlock()
	return run(s.Socket)
}

type Kernel struct {
	ir      *interp.Interp