From ed729255478ac877708c5fe5efb219fe54495a3c Mon Sep 17 00:00:00 2001
From: kxbmap <kxbmap@gmail.com>
Date: Tue, 16 Jul 2013 06:00:49 +0900
Subject: [PATCH] Fix sendNumbers logic

---
 .../factorial/FactorialClientHandler.java     | 19 +++++++++----------
 1 file changed, 9 insertions(+), 10 deletions(-)

diff --git a/example/src/main/java/io/netty/example/factorial/FactorialClientHandler.java b/example/src/main/java/io/netty/example/factorial/FactorialClientHandler.java
index 1e1264a9ef..eb678cdb7f 100644
--- a/example/src/main/java/io/netty/example/factorial/FactorialClientHandler.java
+++ b/example/src/main/java/io/netty/example/factorial/FactorialClientHandler.java
@@ -40,6 +40,7 @@ public class FactorialClientHandler extends SimpleChannelInboundHandler<BigInteg
 
     private ChannelHandlerContext ctx;
     private int receivedMessages;
+    private int next = 1;
     private final int count;
     final BlockingQueue<BigInteger> answer = new LinkedBlockingQueue<BigInteger>();
 
@@ -94,16 +95,14 @@ public class FactorialClientHandler extends SimpleChannelInboundHandler<BigInteg
 
     private void sendNumbers() {
         // Do not send more than 4096 numbers.
-        for (int i = 0; i < 4096; i++) {
-            if (i <= count) {
-                ChannelFuture future = ctx.write(Integer.valueOf(i));
-                if (count == i) {
-                    future.addListener(numberSender);
-                }
-                i ++;
-            } else {
-                break;
-            }
+        ChannelFuture future = null;
+        for (int i = 0; i < 4096 && next <= count; i++) {
+            future = ctx.write(Integer.valueOf(next));
+            next++;
+        }
+        if (next <= count) {
+            assert future != null;
+            future.addListener(numberSender);
         }
         ctx.flush();
     }