Fix code that didn't follow the stream protocol.

Author: brendanburns

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;