Reduce the delay used for Coroutines in tests

Closes gh-30731

spring-core/src/test/kotlin/org/springframework/core/KotlinCoroutinesUtilsTests.kt

@@ -34,7 +34,7 @@ class KotlinCoroutinesUtilsTests {
 	fun deferredToMono() {
 		runBlocking {
 			val deferred: Deferred<String> = async(Dispatchers.IO) {
-				delay(10)
+				delay(1)
 				"foo"
 			}
 			val mono = CoroutinesUtils.deferredToMono(deferred)
@@ -122,12 +122,12 @@ class KotlinCoroutinesUtilsTests {
 	}
 
 	suspend fun suspendingFunction(value: String): String {
-		delay(10)
+		delay(1)
 		return value
 	}
 
 	suspend fun suspendingFunctionWithFlow(): Flow<String> {
-		delay(10)
+		delay(1)
 		return flowOf("foo", "bar")
 	}
 
@@ -136,7 +136,7 @@ class KotlinCoroutinesUtilsTests {
 	}
 
 	suspend fun suspendingFunctionWithContext(value: String): String {
-		delay(10)
+		delay(1)
 		Assertions.assertThat(coroutineContext[CoroutineName]?.name).isEqualTo("name")
 		return value
 	}

spring-messaging/src/test/kotlin/org/springframework/messaging/rsocket/RSocketClientToServerCoroutinesIntegrationTests.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2020 the original author or authors.
+ * Copyright 2002-2023 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -154,13 +154,13 @@ class RSocketClientToServerCoroutinesIntegrationTests {
 
 		@MessageMapping("receive-async")
 		suspend fun receiveAsync(payload: String) {
-			delay(10)
+			delay(1)
 			fireForgetPayloads.tryEmitNext(payload)
 		}
 
 		@MessageMapping("echo-async")
 		suspend fun echoAsync(payload: String): String {
-			delay(10)
+			delay(1)
 			return "$payload async"
 		}
 
@@ -169,7 +169,7 @@ class RSocketClientToServerCoroutinesIntegrationTests {
 			var i = 0
 			return flow {
 				while(true) {
-					delay(10)
+					delay(1)
 					emit("$payload ${i++}")
 				}
 			}
@@ -177,11 +177,11 @@ class RSocketClientToServerCoroutinesIntegrationTests {
 
 		@MessageMapping("echo-stream-async")
 		suspend fun echoStreamAsync(payload: String): Flow<String> {
-			delay(10)
+			delay(1)
 			var i = 0
 			return flow {
 				while(true) {
-					delay(10)
+					delay(1)
 					emit("$payload ${i++}")
 				}
 			}
@@ -189,31 +189,31 @@ class RSocketClientToServerCoroutinesIntegrationTests {
 
 		@MessageMapping("echo-channel")
 		fun echoChannel(payloads: Flow<String>) = payloads.map {
-			delay(10)
+			delay(1)
 			"$it async"
 		}
 
 		@Suppress("UNUSED_PARAMETER")
 		@MessageMapping("thrown-exception")
 		suspend fun handleAndThrow(payload: String): String {
-			delay(10)
+			delay(1)
 			throw IllegalArgumentException("Invalid input error")
 		}
 
 		@MessageMapping("unit-return-value")
 		suspend fun unitReturnValue(payload: String) =
-				if (payload != "bad") delay(10) else throw IllegalStateException("bad")
+				if (payload != "bad") delay(1) else throw IllegalStateException("bad")
 
 		@MessageExceptionHandler
 		suspend fun handleException(ex: IllegalArgumentException): String {
-			delay(10)
+			delay(1)
 			return  "${ex.message} handled"
 		}
 
 		@Suppress("UNUSED_PARAMETER")
 		@MessageExceptionHandler
 		suspend fun handleExceptionWithVoidReturnValue(ex: IllegalStateException) {
-			delay(10)
+			delay(1)
 		}
 	}
 

spring-tx/src/test/kotlin/org/springframework/transaction/annotation/CoroutinesAnnotationTransactionInterceptorTests.kt

@@ -160,48 +160,48 @@ class CoroutinesAnnotationTransactionInterceptorTests {
 	open class TestWithCoroutines {
 
 		open suspend fun suspendingNoValueSuccess() {
-			delay(10)
+			delay(1)
 		}
 
 		open suspend fun suspendingNoValueFailure() {
-			delay(10)
+			delay(1)
 			throw IllegalStateException()
 		}
 
 		open suspend fun suspendingValueSuccess(): String {
-			delay(10)
+			delay(1)
 			return "foo"
 		}
 
 		open suspend fun suspendingValueFailure(): String {
-			delay(10)
+			delay(1)
 			throw IllegalStateException()
 		}
 
 		open fun flowSuccess(): Flow<String> {
 			return flow {
 				emit("foo")
-				delay(10)
+				delay(1)
 				emit("foo")
 			}
 		}
 
 		open suspend fun suspendingFlowSuccess(): Flow<String> {
-			delay(10)
+			delay(1)
 			return flow {
 				emit("foo")
-				delay(10)
+				delay(1)
 				emit("foo")
 			}
 		}
 
 		open suspend fun suspendingValueSuccessWithContext(): String {
-			delay(10)
+			delay(1)
 			return coroutineContext[ExampleContext.Key].toString()
 		}
 
 		open suspend fun suspendingValueFailureWithContext(): String {
-			delay(10)
+			delay(1)
 			throw IllegalStateException(coroutineContext[ExampleContext.Key].toString())
 		}
 	}

spring-tx/src/test/kotlin/org/springframework/transaction/interceptor/AbstractCoroutinesTransactionAspectTests.kt

@@ -337,17 +337,17 @@ abstract class AbstractCoroutinesTransactionAspectTests {
 		private var name: String? = null
 
 		override suspend fun getName(): String? {
-			delay(10)
+			delay(1)
 			return name
 		}
 
 		override suspend fun setName(name: String?) {
-			delay(10)
+			delay(1)
 			this.name = name
 		}
 
 		override suspend fun exceptional(t: Throwable?) {
-			delay(10)
+			delay(1)
 			if (t != null) {
 				throw t
 			}

spring-webflux/src/test/kotlin/org/springframework/web/reactive/result/KotlinInvocableHandlerMethodTests.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2022 the original author or authors.
+ * Copyright 2002-2023 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -134,12 +134,12 @@ class KotlinInvocableHandlerMethodTests {
 	class CoroutinesController {
 
 		suspend fun singleArg(q: String?): String {
-			delay(10)
+			delay(1)
 			return "success:$q"
 		}
 
 		suspend fun noArgs(): String {
-			delay(10)
+			delay(1)
 			return "success"
 		}
 
@@ -149,12 +149,12 @@ class KotlinInvocableHandlerMethodTests {
 
 		@ResponseStatus(HttpStatus.CREATED)
 		suspend fun created(): String {
-			delay(10)
+			delay(1)
 			return "created"
 		}
 
 		suspend fun response(response: ServerHttpResponse) {
-			delay(10)
+			delay(1)
 			response.headers.add("foo", "bar")
 		}
 	}
@@ -162,7 +162,7 @@ class KotlinInvocableHandlerMethodTests {
 	private class PrivateCoroutinesController {
 
 		suspend fun singleArg(q: String?): String {
-			delay(10)
+			delay(1)
 			return "success:$q"
 		}
 	}

spring-webflux/src/test/kotlin/org/springframework/web/reactive/result/method/annotation/CoroutinesIntegrationTests.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2022 the original author or authors.
+ * Copyright 2002-2023 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -172,7 +172,7 @@ class CoroutinesIntegrationTests : AbstractRequestMappingIntegrationTests() {
 
 		@GetMapping("/suspending-flow")
 		suspend fun suspendingFlowEndpoint(): Flow<String> {
-			delay(10)
+			delay(1)
 			return flow {
 				emit("foo")
 				delay(1)