Addtimeout before read confirmed channels

kneu-messenger-pigeon · Oct 14, 2023 · 158b334 · 158b334
1 parent 9051514
commit 158b334
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/eventloop.go b/eventloop.go
@@ -8,6 +8,7 @@ import (
 	"os/signal"
 	"runtime"
 	"syscall"
+	"time"
 )
 
 type EventLoop struct {
@@ -34,6 +35,7 @@ func (eventLoop *EventLoop) execute() {
 
 	go eventLoop.dispatchConfirmedEvent(ctx)
 	runtime.Gosched()
+	time.Sleep(time.Millisecond * 300)
 	eventLoop.dispatchIncomingEvent(ctx)
 }
 

diff --git a/eventloop_test.go b/eventloop_test.go
@@ -81,7 +81,7 @@ func TestEventLoopExecute(t *testing.T) {
 			currentYearWatcher:     currentYearWatcher,
 		}
 
-		timeout := time.After(time.Millisecond * 500)
+		timeout := time.After(time.Second)
 		done := make(chan bool)
 		go func() {
 			eventLoop.execute()