Code sample for a blog post

BatchLoaderStep1.kt

class BatchLoader<ID, T>(
  /* ... */
) : Loader<ID, T> {
  private val requests = Channel<LoadRequest<ID, T>>(Channel.UNLIMITED) // UNLIMITED allows to queue requests
  
  override suspend fun loadByIds(ids: Set<ID>): Map<ID, T> {
    val request = LoadRequest<ID, T>(ids) // create a request
    requests.send(request) // queue the request
    return request.result.await() // await for the request to be fulfilled
  }
}