(stream pb.Api_GetFeaturesServer)
| 111 | } |
| 112 | |
| 113 | func (serv *MetadataServer) GetFeatures(stream pb.Api_GetFeaturesServer) error { |
| 114 | for { |
| 115 | name, err := stream.Recv() |
| 116 | if err == io.EOF { |
| 117 | return nil |
| 118 | } |
| 119 | if err != nil { |
| 120 | serv.Logger.Errorf("Failed to read client request: %v", err) |
| 121 | return err |
| 122 | } |
| 123 | proxyStream, err := serv.meta.GetFeatures(stream.Context()) |
| 124 | if err != nil { |
| 125 | return err |
| 126 | } |
| 127 | sErr := proxyStream.Send(name) |
| 128 | if sErr != nil { |
| 129 | return sErr |
| 130 | } |
| 131 | res, err := proxyStream.Recv() |
| 132 | if err != nil { |
| 133 | return err |
| 134 | } |
| 135 | sendErr := stream.Send(res) |
| 136 | if sendErr != nil { |
| 137 | return sendErr |
| 138 | } |
| 139 | } |
| 140 | } |
| 141 | |
| 142 | func (serv *MetadataServer) GetFeatureVariants(stream pb.Api_GetFeatureVariantsServer) error { |
| 143 | for { |
nothing calls this directly
no test coverage detected