Kefir test utils upgrade

extend-expect.d.ts

@@ -8,7 +8,7 @@ declare namespace jest {
     toEmit<V, E>(events: import('kefir-test-utils').Event<V, E>[], cb?: () => void): R
     toEmitInTime<V, E>(
       events: import('kefir-test-utils').EventWithTime<V, E>[],
-      cb?: (tick: (s: number) => void, clock: import('lolex').Clock) => void,
+      cb?: (tick: (s: number) => void, clock: import('@sinonjs/fake-timers').Clock) => void,
       opts?: {reverseSimultaneous?: boolean; timeLimit?: number}
     ): R
     toFlowErrors<V, E>(source?: import('kefir').Observable<V, E>): R

jest-kefir.d.ts

@@ -1,6 +1,6 @@
 import {Observable, Stream, Property} from 'kefir'
 import {Helpers as KHelpers, Event} from 'kefir-test-utils'
-import {Clock} from 'lolex'
+import {Clock} from '@sinonjs/fake-timers'
 
 export interface Helpers extends KHelpers {
   extensions: jest.ExpectExtendMap

package.json

@@ -39,7 +39,7 @@
     "@types/jest": "^27.0.3",
     "@types/kefir": "^3.0.0",
     "@types/node": "^14.0.1",
-    "kefir-test-utils": "^1.1.1"
+    "kefir-test-utils": "^2.0.0"
   },
   "peerDependencies": {
     "jest": ">=24.0.0",

src/index.js

@@ -79,13 +79,16 @@ export default function jestKefir(Kefir) {
     },
 
     toEmitInTime(received, expected, cb = noop, {timeLimit = 10000, reverseSimultaneous = false} = {}) {
-      let log = null
+      let log,
+        unwatch = null
 
       withFakeTime((tick, clock) => {
-        log = watchWithTime(received)
+        // prettier-ignore
+        ({log, unwatch} = watchWithTime(received))
         cb(tick, clock)
         tick(timeLimit)
       }, reverseSimultaneous)
+      unwatch()
 
       const options = {
         comment: 'Emitted values',