micro-server-grpc/response.go

package grpc

import (
	"io"

	"github.com/unistack-org/micro/v3/codec"
	"github.com/unistack-org/micro/v3/metadata"
)

type rpcResponse struct {
	rw       io.ReadWriter
	header   metadata.Metadata
	codec    codec.Codec
	endpoint string
	service  string
	method   string
	target   string
}

func (r *rpcResponse) Codec() codec.Codec {
	return r.codec
}

func (r *rpcResponse) WriteHeader(hdr metadata.Metadata) {
	for k, v := range hdr {
		r.header[k] = v
	}
}

func (r *rpcResponse) Write(b []byte) error {
	return r.codec.Write(r.rw, &codec.Message{
		Header: r.header,
		Body:   b,
	}, nil)
}