Merge pull request #162 from brendandburns/pff

Fix code that didn't follow the stream protocol.

Author: mbohlool

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

@@ -52,9 +52,10 @@ public static void main(String[] args) throws IOException, ApiException, Interru
 
         PortForward forward = new PortForward();
         List<Integer> ports = new ArrayList<>();
+        ports.add(8080);
         ports.add(80);
         final PortForward.PortForwardResult result =
-            forward.forward("default", "nginx-4217019353-fg6zx", ports);
+            forward.forward("default", "nginx-d5dc44cf7-x7475", ports);
 
         ServerSocket ss = new ServerSocket(8080);
 

util/src/main/java/io/kubernetes/client/PortForward.java

@@ -135,7 +135,7 @@ public PortForwardResult(WebSocketStreamHandler handler, List<Integer> ports) th
          */
         public void init() throws IOException {
             for (int i = 0; i < ports.size(); i++) {
-                InputStream is = handler.getInputStream(i);
+                InputStream is = handler.getInputStream(i * 2);
                 byte[] data = new byte[2];
                 is.read(data);
                 int port = (data[0] & 0xFF) + (data[1] & 0xFF) * 256;