change source send frequency

yomorun · May 18, 2022 · 4a493f1 · 4a493f1
1 parent b7950fc
commit 4a493f1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/example/4-cascading-zipper/source-1/source.go b/example/4-cascading-zipper/source-1/source.go
@@ -58,7 +58,7 @@ func generateAndSendData(stream yomo.Source) error {
 		i++
 
 		log.Printf("[source] ✅ Emit %s to YoMo-Zipper", data)
-		time.Sleep(10 * time.Millisecond)
+		time.Sleep(1000 * time.Millisecond)
 	}
 	return nil
 }
diff --git a/example/4-cascading-zipper/source-2/source.go b/example/4-cascading-zipper/source-2/source.go
@@ -58,7 +58,7 @@ func generateAndSendData(stream yomo.Source) error {
 		i++
 
 		log.Printf("[source] ✅ Emit %s to YoMo-Zipper", data)
-		time.Sleep(10 * time.Millisecond)
+		time.Sleep(1000 * time.Millisecond)
 	}
 	return nil
 }