Future: get() with (long timeout, TimeUnit unit)

[k33g]

Hello 🌍

• gololang.concurrent.async.Future has not a get method to handle a timeout
• so gololang.concurrent.async.AssignedFuture does not implement this method

What I'm doing instead:

  let concurrentTask = |task, timeout| {
    let executor = Executors.newSingleThreadExecutor()
    return trying({
      let future = executor: submit(asInterfaceInstance(java.util.concurrent.Callable.class, {
        return task()
      }))
      let res = future: get(timeout, MILLISECONDS())
      executor: shutdown()
      return res
    })
  }

  concurrentTask({
    sleep(2000_L)
    return "Hello 🌍"
  }, 1000_L)
  : either(
    recover=|error| {
      println("😡")
    },
    mapping=|result| {
      println(result)
    }
  )