myMethod Function { foo -> bar }

myMethod( foo -> bar )

spring-boot-starter-webflux

'spring-webflux', version: '5.2.0.M2'

Schedulers.boundedElastic()

BlockHound

class MdcTaskDecorator implements TaskDecorator {

  @Override
  public Runnable decorate(Runnable runnable) {
    // Right now: Web thread context !
    // (Grab the current thread MDC data)
    Map<String, String> contextMap = MDC.getCopyOfContextMap();
    return () -> {
      try {
        // Right now: @Async thread context !
        // (Restore the Web thread context's MDC data)
        MDC.setContextMap(contextMap);
        runnable.run();
      } finally {
        MDC.clear();
      }
    };
  }
}

@Configuration
@EnableAsync
class AsynchConfig : AsyncConfigurerSupport() {

    override fun getAsyncExecutor(): Executor {
        val executor = ThreadPoolTaskExecutor()
        executor.setTaskDecorator(MDCTaskDecorator())
        executor.initialize()
        return executor
    }
}

WebMvc.fn

@RequestMapping

MockMvc

MockMvc

<form name="users" action="POST">
<input type="text" name="someInfo">
<input type="text" name="users[name][0]">
<input type="text" name="users[surname][0]">
<input type="text" name="users[name][1]">
<input type="text" name="users[surname][1]">
</form>

data class InputForm(val someInfo: String, val users: Map<String, List<String>)

@PostMapping("/users")
fun updateUsers(inputForm: InputForm) {
  // access input form data like "someInfo" and the map "user"
}

router {
  POST("/users", userController::updateUsers)
}

fun updateUsers(request: ServerRequest): ServerResponse {
  val inputForm = request.body<InputForm>()
  // do some stuff
  return ServerResponse.ok().render("success.html")
}

org.springframework.web.HttpMediaTypeNotSupportedException: Content type 'application/x-www-form-urlencoded;charset=UTF-8' not supported

@Configuration
class FooConfiguration {
    @Value("\${foo.bar}")
    lateinit var bar: String
}

myProps:
  configs:
    someName:
      x: "foo"
      y: 1
    anotherName:
      x: "bar"
      y: 2

@ConstructorBinding
@ConfigurationProperties(prefix = "myProps")
data class MyProperties(val configs: Map<String, MyCustomProperties>)

data class MyCustomProperties(val x: String, val y: Int)

MyCustomProperties

Webflux

async/await

./gradlew bootJar

* What went wrong: 
Plugin [id: 'org.springframework.boot', version: '2.1.4.RELEASE'] was not found in any of the following sources: 
 
- Gradle Core Plugins (plugin is not in 'org.gradle' namespace) 
- Plugin Repositories (could not resolve plugin artifact 'org.springframework.boot:org.springframework.boot.gradle.plugin:2.1.4.RELEASE') 
  Searched in the following repositories: 
    Gradle Central Plugin Repository