(a typeurl.Any)
| 109 | } |
| 110 | |
| 111 | func (cs *clientStream) Send(a typeurl.Any) (err error) { |
| 112 | err = cs.s.Send(typeurl.MarshalProto(a)) |
| 113 | if !errors.Is(err, io.EOF) { |
| 114 | err = errgrpc.ToNative(err) |
| 115 | } |
| 116 | return |
| 117 | } |
| 118 | |
| 119 | func (cs *clientStream) Recv() (a typeurl.Any, err error) { |
| 120 | a, err = cs.s.Recv() |