From 0655a4bb992a40088373643cf39021743e023d02 Mon Sep 17 00:00:00 2001
From: Marcos Lilljedahl <marcosnils@gmail.com>
Date: Wed, 2 Aug 2017 13:31:41 -0300
Subject: [PATCH] Set session ticker inside cron

---
 scheduler/scheduler.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go
index 94051b1..1156ef3 100644
--- a/scheduler/scheduler.go
+++ b/scheduler/scheduler.go
@@ -96,7 +96,6 @@ func (s *scheduler) Start() {
 	for _, session := range s.scheduledSessions {
 		ctx, cancel := context.WithCancel(context.Background())
 		session.cancel = cancel
-		session.ticker = time.NewTicker(1 * time.Second)
 		go s.cron(ctx, session)
 	}
 	s.event.On(event.SESSION_NEW, func(sessionId string, args ...interface{}) {
@@ -129,6 +128,7 @@ func (s *scheduler) register(session *types.Session) *scheduledSession {
 }
 
 func (s *scheduler) cron(ctx context.Context, session *scheduledSession) {
+	session.ticker = time.NewTicker(1 * time.Second)
 	for {
 		select {
 		case <-session.ticker.C:
@@ -167,7 +167,6 @@ func (s *scheduler) Schedule(session *types.Session) error {
 	scheduledSession := s.register(session)
 	ctx, cancel := context.WithCancel(context.Background())
 	scheduledSession.cancel = cancel
-	scheduledSession.ticker = time.NewTicker(1 * time.Second)
 	go s.cron(ctx, scheduledSession)
 	return nil
 }