Function getAllChanges

helper/server/downstream_test.go:183–199

(changesClient remote.Downstream_ChangesClient)

}

func getAllChanges(changesClient remote.Downstream_ChangesClient) ([]*remote.Change, error) {
	changes := make([]*remote.Change, 0, 32)
	for {
		changeChunk, err := changesClient.Recv()
		if changeChunk != nil {
			changes = append(changes, changeChunk.Changes...)
		}

		if err == io.EOF {
			break
		} else if err != nil {
			return nil, err
		}
	}

	return changes, nil
}