From 4a493f1299043dee14b680ccf6f9cd4dca212e7e Mon Sep 17 00:00:00 2001 From: venjiang Date: Thu, 19 May 2022 00:10:54 +0800 Subject: [PATCH] change source send frequency --- example/4-cascading-zipper/source-1/source.go | 2 +- example/4-cascading-zipper/source-2/source.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 }