(stream sourceStream)
| 838 | } |
| 839 | |
| 840 | func (client *Client) parseSourceStream(stream sourceStream) ([]*Source, error) { |
| 841 | sources := make([]*Source, 0) |
| 842 | for { |
| 843 | serial, err := stream.Recv() |
| 844 | if err == io.EOF { |
| 845 | break |
| 846 | } else if err != nil { |
| 847 | return nil, err |
| 848 | } |
| 849 | sources = append(sources, wrapProtoSource(serial)) |
| 850 | } |
| 851 | return sources, nil |
| 852 | } |
| 853 | |
| 854 | type sourceVariantStream interface { |
| 855 | Recv() (*pb.SourceVariant, error) |
no test coverage detected