| 494 | } |
| 495 | |
| 496 | func (serv *MetadataServer) ListSources(in *pb.Empty, stream pb.Api_ListSourcesServer) error { |
| 497 | proxyStream, err := serv.meta.ListSources(stream.Context(), in) |
| 498 | if err != nil { |
| 499 | return err |
| 500 | } |
| 501 | for { |
| 502 | res, err := proxyStream.Recv() |
| 503 | if err == io.EOF { |
| 504 | return nil |
| 505 | } |
| 506 | if err != nil { |
| 507 | return err |
| 508 | } |
| 509 | sendErr := stream.Send(res) |
| 510 | if sendErr != nil { |
| 511 | return sendErr |
| 512 | } |
| 513 | } |
| 514 | } |
| 515 | |
| 516 | func (serv *MetadataServer) ListTrainingSets(in *pb.Empty, stream pb.Api_ListTrainingSetsServer) error { |
| 517 | proxyStream, err := serv.meta.ListTrainingSets(stream.Context(), in) |