datasourcex-reactivestreams

Bind.using(dataSource) {
  to("my-service") {
    active {
      record {
        path(
            path = "/example/activeSubject",
            publisher =
                Flux.interval(Duration.ofSeconds(1)).map { aLong: Long ->
                  mapOf("Count" to aLong.toString())
                },
        ) {
          recordType = RecordType.TYPE1
        }
      }

      json {
        pattern(
            pattern = "/example/{username}/subjectPattern/{myKey}",
            configure = { objectMappings = mapOf("username" to "%u") },
            supplier = { _, parameters ->
              val username = parameters["username"]
              val myKey = parameters["myKey"]
              Flux.interval(Duration.ofSeconds(1)).map { count: Long ->
                JsonObject("$username $myKey $count")
              }
            },
        )
      }
    }
  }
}