Method dispatch

api/rpc/client.go:515–607

dispatch is the main loop of the client. It sends read messages to waiting calls to Call and BatchCall and subscription notifications to registered subscriptions.

(conn net.Conn)

// It sends read messages to waiting calls to Call and BatchCall
// and subscription notifications to registered subscriptions.
func (c *Client) dispatch(conn net.Conn) {
	// Spawn the initial read loop.
	go c.read(conn)

	var (
		lastOp        *requestOp    // tracks last send operation
		requestOpLock = c.requestOp // nil while the send lock is held
		reading       = true        // if true, a read loop is running
	)
	defer close(c.didQuit)
	defer func() {
		c.closeRequestOps(ErrClientQuit)
		conn.Close()
		if reading {
			// Empty read channels until read is dead.
			for {
				select {
				case <-c.readResp:
				case <-c.readErr:
					return
				}
			}
		}
	}()

	for {
		select {
		case <-c.close:
			return

		// Read path.
		case batch := <-c.readResp:
			for _, msg := range batch {
				switch {
				case msg.isNotification():
					log.Debug("", "msg", func() string {
						return fmt.Sprint("<-readResp: notification ", msg)
					}())
					c.handleNotification(msg)
				case msg.isResponse():
					log.Debug("", "msg", func() string {
						return fmt.Sprint("<-readResp: response ", msg)
					}())
					c.handleResponse(msg)
				default:
					log.Debug("", "msg", func() string {
						return fmt.Sprint("<-readResp: dropping weird message", msg)
					}())
					// TODO: maybe close
				}
			}

		case err := <-c.readErr:
			log.Debug("<-readErr", "err", err)
			c.closeRequestOps(err)
			conn.Close()
			reading = false