diff --git a/libraries-data/src/main/java/com/baeldung/ignite/stream/IgniteStream.java b/libraries-data/src/main/java/com/baeldung/ignite/stream/IgniteStream.java
index 839da36c22..c72a4b1f02 100644
--- a/libraries-data/src/main/java/com/baeldung/ignite/stream/IgniteStream.java
+++ b/libraries-data/src/main/java/com/baeldung/ignite/stream/IgniteStream.java
@@ -14,6 +14,8 @@ import java.nio.file.Paths;
 
 public class IgniteStream {
 
+    private static final Gson GSON = new Gson();
+
     public static void main(String[] args) throws Exception {
 
         Ignition.setClientMode(true);
@@ -29,16 +31,16 @@ public class IgniteStream {
             employee.setEmployed(true);
             e.setValue(employee);
 
-            return null;
+            return employee;
         }));
 
         Path path = Paths.get(IgniteStream.class.getResource("employees.txt").toURI());
 
         Files.lines(path)
-                .forEach(line -> {
-                    Employee employee = new Gson().fromJson(line, Employee.class);
-                    streamer.addData(employee.getId(), employee);
-                });
-
-    }
+          .forEach(line -> {
+              Employee employee = GSON.fromJson(line, Employee.class);
+              streamer.addData(employee.getId(), employee);
+          });
+    }    
+    
 }