updates and fixes

CHANGELOG.md

@@ -10,6 +10,7 @@
   * New type `KronSchedulerTz`
 * `SchedulerFlow` has been deprecated
 * New extension `asTzFlow` and small changes in `asFlow` logic
+* `merge` extensions now return `CollectionKronScheduler` instead of just `KronScheduler`
 
 ## 0.5.1
 

src/commonMain/kotlin/dev/inmo/krontab/StringParser.kt

@@ -84,13 +84,10 @@ fun createSimpleScheduler(
             offsetParsed = offsetParsed ?: offsetFromString
             dayOfWeekParsed = dayOfWeekParsed ?: dayOfWeekFromString
             when {
-                dayOfWeekFromString != null -> return@forEach
+                dayOfWeekFromString != null || offsetFromString != null -> return@forEach
-                offsetFromString == null && yearParsed == null -> {
+                yearParsed == null -> {
                     yearParsed = parseYears(it)
                 }
-                offsetFromString != null && offsetParsed == null -> {
-                    offsetParsed = offsetFromString
-                }
             }
         }
     }
@@ -150,4 +147,4 @@ fun KrontabTemplate.toKronScheduler(): KronScheduler = buildSchedule(this)
 /**
  * Shortcut for [buildSchedule]
  */
-fun KrontabTemplate.toKronScheduler(defaultOffset: Minutes): KronSchedulerTz = buildSchedule(this, defaultOffset)
+fun KrontabTemplate.toKronScheduler(defaultOffset: Minutes): KronSchedulerTz = buildSchedule(this, defaultOffset)

src/commonTest/kotlin/dev/inmo/krontab/utils/TimeZoneTest.kt

@@ -10,14 +10,17 @@ class TimeZoneTest {
     @Test
     fun testDifferentTimeZonesReturnsDifferentTimes() {
         val scheduler = buildSchedule { seconds { every(1) } }
-        val now = DateTime.now()
+        val baseDate = DateTime.now().startOfWeek
         runTest {
-            for (i in 0 .. 24) {
+            for (i in 0 until 7) {
-                val nowTz = now.toOffset(i.hours)
+                val now = baseDate + i.days
-                val next = scheduler.next(nowTz)!!
+                for (j in 0 .. 24) {
-                assertEquals(
+                    val nowTz = now.toOffset(j.hours)
-                    (nowTz + 1.seconds).utc.unixMillisLong, next.utc.unixMillisLong
+                    val next = scheduler.next(nowTz)!!
-                )
+                    assertEquals(
+                        (nowTz + 1.seconds).utc.unixMillisLong, next.utc.unixMillisLong
+                    )
+                }
             }
         }
     }