diff --git a/bigtable/internal/testproxy/proxy.go b/bigtable/internal/testproxy/proxy.go index b4e2eddcd565..f2d51a817521 100644 --- a/bigtable/internal/testproxy/proxy.go +++ b/bigtable/internal/testproxy/proxy.go @@ -573,6 +573,12 @@ func (s *goTestProxyServer) ReadRows(ctx context.Context, req *pb.ReadRowsReques var c int32 var rowsPb []*btpb.Row lim := req.GetCancelAfterRows() + + reversed := req.GetRequest().GetReversed() + opts := []bigtable.ReadOption{} + if reversed { + opts = append(opts, bigtable.ReverseScan()) + } err = t.ReadRows(ctx, rs, func(r bigtable.Row) bool { c++ @@ -585,7 +591,7 @@ func (s *goTestProxyServer) ReadRows(ctx context.Context, req *pb.ReadRowsReques } rowsPb = append(rowsPb, rpb) return true - }) + }, opts...) res := &pb.RowsResult{ Status: &statpb.Status{