--- a/src/parallel_execution/examples/gearsFile/GearsFile.h	Tue Oct 19 18:56:44 2021 +0900
+++ b/src/parallel_execution/examples/gearsFile/GearsFile.h	Thu Oct 21 13:28:10 2021 +0900
@@ -1,5 +1,6 @@
 typedef struct GearsFile <> {
     union Data* gearsFile;
+    union Data* data;
     struct Queue* inputStreamQueue;
     struct Queue* outputStreamQueue;
     struct Queue* dataQueue;

--- a/src/parallel_execution/examples/gearsFile/GearsFileImpl.cbc	Tue Oct 19 18:56:44 2021 +0900
+++ b/src/parallel_execution/examples/gearsFile/GearsFileImpl.cbc	Thu Oct 21 13:28:10 2021 +0900
@@ -28,6 +28,7 @@
     gearsFile->test = C_testGearsFileImpl;
     return gearsFile;
 }
+
 __code readData(struct GearsFileImpl* gearsFile, Queue* outputStreamQueue, __code next(...)) {
     printf("readData\n");
     
@@ -43,6 +44,17 @@
 }
 
 __code test(struct GearsFileImpl* gearsFile, FileData* fileData, __code next(...)) {
-    printf("%s\n", fileData->string);
+    if (fileData ==NULL){
+        printf("End of File\n");
+    } else {
+        printf("%s\n", fileData->string);
+    }
     goto next(...);
 }
+
+__code testGearsFileImpl_stub(struct Context* context){
+	GearsFileImpl* gearsFile = (GearsFileImpl*)GearImpl(context, GearsFile, gearsFile);
+    FileData* fileData = Gearef(context, Queue)->data;
+    enum Code next = Gearef(context, GearsFile)->next;
+    goto testGearsFileImpl(context, gearsFile, fileData, next);
+}