fix issues

Author: karthikkondapally

examples/src/main/java/io/kubernetes/client/examples/PagerExample.java

@@ -21,17 +21,22 @@ public static void main(String[] args) {
       client.getHttpClient().setReadTimeout(60, TimeUnit.SECONDS);
       Configuration.setDefaultApiClient(client);
       CoreV1Api api = new CoreV1Api();
+      int i=0;
       Call call =
+          api.listConfigMapForAllNamespacesCall(null, null, null, null, 1, null, null, null, null, null, null);
+          
           api.listNamespaceCall(
-              null, "pretty", null, null, null, null, null, null, null, null, null);
+              null, "pretty", null, null, null, 20, null, null, null, null, null);
 
       Pager pager = new Pager(client, call, 1, new TypeToken<V1NamespaceList>() {}.getType());
-      while (pager.hasNext()) {
-        V1NamespaceList list = pager.next();
+      while (pager.hasNextPage()) {
+        V1NamespaceList list = pager.getnextPage();
         List<V1Namespace> items = list.getItems();
+        System.out.println("count:"+items.size());
         for (V1Namespace namespace : items) {
           System.out.println(namespace.getMetadata().getName());
         }
+        System.out.println("------------------"+(++i));
       }
     } catch (Exception e) {
       e.printStackTrace();

util/src/main/java/io/kubernetes/client/pager/Pager.java

@@ -14,17 +14,18 @@
 import java.io.IOException;
 import java.lang.reflect.Field;
 import java.lang.reflect.Type;
+import java.util.function.Function;
 
 public class Pager {
   private Request originalRequest;
   private String _continue;
   private String resourceVersion;
-  private int limit;
+  private Integer limit;
   private ApiClient client;
   private Call call;
   private Type listType;
 
-  public Pager(ApiClient client, Call call, int limit, Type listType) {
+  public Pager(ApiClient client, Call call, Integer limit, Type listType) {
     this.client = client;
     this.call = call;
     this.limit = limit;
@@ -51,12 +52,10 @@ public <T> T next()
     } else if (_continue == null && originalRequest != null) {
       // list was exhausted at server
       V1ConfigMapList list =
-          client.getJSON().deserialize("{}", new TypeToken<V1ConfigMapList>() {}.getType());
-    } else {
-      // subsequent calls
+          client.getJSON().deserialize("{}", listType);
+    }
       Request nextRequest = transFormRequest();
       call = client.getHttpClient().newCall(nextRequest);
-    }
     return executeRequest(client, call, listType);
   }
 
@@ -66,9 +65,10 @@ private Request transFormRequest() {
             .httpUrl()
             .newBuilder()
             .setQueryParameter("continue", _continue)
-            .setQueryParameter("limit", String.valueOf(limit))
+            .setQueryParameter("limit",  (limit==null)?"-1":String.valueOf(limit))
             // .addQueryParameter("resourceversion", resourceVersion)
             .build();
+    System.out.println(url);
     Request request = new Request.Builder().headers(originalRequest.headers()).url(url).build();
     return request;
   }