| 534 | } |
| 535 | |
| 536 | func (serv *MetadataServer) ListModels(in *pb.Empty, stream pb.Api_ListModelsServer) error { |
| 537 | proxyStream, err := serv.meta.ListModels(stream.Context(), in) |
| 538 | if err != nil { |
| 539 | return err |
| 540 | } |
| 541 | for { |
| 542 | res, err := proxyStream.Recv() |
| 543 | if err == io.EOF { |
| 544 | return nil |
| 545 | } |
| 546 | if err != nil { |
| 547 | return err |
| 548 | } |
| 549 | sendErr := stream.Send(res) |
| 550 | if sendErr != nil { |
| 551 | return sendErr |
| 552 | } |
| 553 | } |
| 554 | } |
| 555 | |
| 556 | func (serv *MetadataServer) ListEntities(in *pb.Empty, stream pb.Api_ListEntitiesServer) error { |
| 557 | proxyStream, err := serv.meta.ListEntities(stream.Context(), in) |