Added test for FileByteChunkConsumer

src/test/java/com/sangupta/jerry/io/TestFileByteChunkConsumer.java

@@ -0,0 +1,61 @@
+package com.sangupta.jerry.io;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.concurrent.atomic.AtomicLong;
+
+import org.apache.commons.io.FileUtils;
+import org.junit.Assert;
+import org.junit.Test;
+
+import com.sangupta.jerry.consume.GenericConsumer;
+import com.sangupta.jerry.util.StringUtils;
+
+/**
+ * Unit tests for {@link FileByteChunkConsumer} class
+ * 
+ * @author sangupta
+ *
+ */
+public class TestFileByteChunkConsumer {
+
+	@Test
+	public void test() throws IOException {
+		File file = File.createTempFile("jerry-core-", ".bin");
+		file.deleteOnExit();
+
+		String contents = StringUtils.getRandomString(5000);
+		byte[] bytes = contents.getBytes();
+
+		FileUtils.writeByteArrayToFile(file, bytes);
+
+		final AtomicLong al = new AtomicLong(100); 
+		GenericConsumer<byte[]> consumer = new GenericConsumer<byte[]>() {
+
+			@Override
+			public boolean before() {
+				al.set(0);
+				return super.before();
+			}
+
+			@Override
+			public boolean consume(byte[] data) {
+				al.addAndGet(data.length);
+				return true;
+			}
+
+			@Override
+			public void after() {
+				al.addAndGet(50);
+				super.after();
+			}
+		};
+
+		FileByteChunkConsumer fileConsumer = new FileByteChunkConsumer(file, consumer);
+		fileConsumer.consume();
+
+		// check now
+		Assert.assertEquals(bytes.length + 50, al.get()); // 50 because we added 50 in after
+	}
+
+}