| 153 | } |
| 154 | |
| 155 | type grpcCodec struct { |
| 156 | // headers |
| 157 | id string |
| 158 | target string |
| 159 | method string |
| 160 | endpoint string |
| 161 | |
| 162 | s grpc.ClientStream |
| 163 | c encoding.Codec |
| 164 | } |
| 165 | |
| 166 | func (g *grpcCodec) ReadHeader(m *codec.Message, mt codec.MessageType) error { |
| 167 | md, err := g.s.Header() |
nothing calls this directly
no outgoing calls
no test coverage detected