diff --git a/example/4-cascading-zipper/source-1/source.go b/example/4-cascading-zipper/source-1/source.go index 6fab06068..ba7856fd4 100644 --- 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 index 87fa62a3b..f7b7a499b 100644 --- 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 }