Unified · Split
| @@ -74,6 +74,7 @@ it.layer(NodeServices.layer)("AnalyticsService test", (it) => { · 73 unmodified lines | |||
| 74 | const runtimeLayer = telemetryLayer.pipe( | 74 | const runtimeLayer = telemetryLayer.pipe( |
| 75 | Layer.provide(configLayer), | 75 | Layer.provide(configLayer), |
| 76 | Layer.provideMerge(NodeHttpServer.layerTest), | 76 | Layer.provideMerge(NodeHttpServer.layerTest), |
| 77 | Layer.provideMerge(TestClock.layer()), | ||
| 77 | ); | 78 | ); |
| 78 | 79 | ||
| 79 | yield* Effect.gen(function* () { | 80 | yield* Effect.gen(function* () { |
| @@ -169,7 +170,7 @@ it.layer(NodeServices.layer)("AnalyticsService test", (it) => { · 89 unmodified lines | |||
| 169 | 170 | ||
| 170 | yield* TestClock.adjust(AnalyticsService.ANALYTICS_FLUSH_INTERVAL); | 171 | yield* TestClock.adjust(AnalyticsService.ANALYTICS_FLUSH_INTERVAL); |
| 171 | yield* Deferred.await(receivedRequest).pipe(Effect.timeout("1 second"), TestClock.withLive); | 172 | yield* Deferred.await(receivedRequest).pipe(Effect.timeout("1 second"), TestClock.withLive); |
| 172 | }).pipe(Effect.provide(runtimeLayer), Effect.provide(TestClock.layer())); | 173 | }).pipe(Effect.provide(runtimeLayer)); |
| 173 | 174 | ||
| 174 | const batchRequests = capturedRequests.filter( | 175 | const batchRequests = capturedRequests.filter( |
| 175 | (request): request is RecordedBatchRequest & { readonly body: RecordedBatchBody } => | 176 | (request): request is RecordedBatchRequest & { readonly body: RecordedBatchBody } => |