()
| 117 | } |
| 118 | |
| 119 | func (cs *clientStream) Recv() (a typeurl.Any, err error) { |
| 120 | a, err = cs.s.Recv() |
| 121 | if !errors.Is(err, io.EOF) { |
| 122 | err = errgrpc.ToNative(err) |
| 123 | } |
| 124 | return |
| 125 | } |
| 126 | |
| 127 | func (cs *clientStream) Close() error { |
| 128 | return cs.s.CloseSend() |