Simple RPC skeleton for experience report

simplerpc.go

type Conn struct {
	wc io.WriteCloser
	// ... other internal state ...
}

func NewConn(rwc io.ReadWriteCloser) *Conn {
	c := &Conn{wc: rwc}
	go c.receive(rwc)
	return c
}

func (c *Conn) receive(r io.Reader) {
	for {
		msg, err := decode(r)
		if err != nil {
			return
		}
		// ... Process message ...
	}
}

func (c *Conn) SendRPC( /* ... */ ) *Answer {
	if err := encode(c.wc, makeCallMsg()); err != nil {
		return ErrorAnswer(err)
	}
	// ...
}

func main() {
	rwc1, rwc2 := net.Pipe()
	conn1 := NewConn(rwc1)
	conn2 := NewConn(rwc2)

	ans1 := conn1.SendRPC()
	ans2 := conn1.SendRPC()
	// ...
}