Method readPipe

p2p/client.go:471–495

()

}

func (c *client) readPipe() (out chan []byte) {
	out = make(chan []byte, 10)
	go func() {
		defer close(out)
		for {
			var buffer []byte
			var err error
			select {
			case <-c.ctx.Done():
				return
			default:
				buffer, err = readFrom(c.conn)
				if err != nil {
					c.reportError(errors.Errorf("readPipe: %w", err))
					return
				}
			}
			select {
			case <-c.ctx.Done():
			case out <- buffer:
			}
		}
	}()
	return out
}

func encodeProto(msg proto.Message, sender []byte, signFn signFunc, nonce uint64, replyFlag bool) (bytes []byte, err error) {
	var anything *any.Any