(stream providerStream)
| 1010 | } |
| 1011 | |
| 1012 | func (client *Client) parseProviderStream(stream providerStream) ([]*Provider, error) { |
| 1013 | providers := make([]*Provider, 0) |
| 1014 | for { |
| 1015 | serial, err := stream.Recv() |
| 1016 | if err == io.EOF { |
| 1017 | break |
| 1018 | } else if err != nil { |
| 1019 | return nil, err |
| 1020 | } |
| 1021 | providers = append(providers, wrapProtoProvider(serial)) |
| 1022 | } |
| 1023 | return providers, nil |
| 1024 | } |
| 1025 | |
| 1026 | func (client *Client) ListEntities(ctx context.Context) ([]*Entity, error) { |
| 1027 | stream, err := client.GrpcConn.ListEntities(ctx, &pb.Empty{}) |
no test coverage detected