正在删除ExecControl以升级到Ratepack v1.1.1

Question

我正在学习Ratpack并使用多种资源。我有以下接口和类，它在Ratpack v0.9.18中工作，但在v1.1.1中由于删除了ExecControl接口而失败。

//file: src/main/groovy/app/UserService.groovy
package app
import ratpack.exec.Promise
interface UserService {
  Promise<Void> save (User user)
  Promise<List<User>> getUsers ()
}
//file: src/main/groovy/app/DefaultUserService.groovy
package app
import ratpack.exec.ExecControl
import ratpack.exec.Promise
class DefaultUserService implements UserService {
  private final List storage = []
  @Override
  Promise<Void> save (User user) {
    storage << user
    ExecControl.current ().promiseOf (null)
  }
  @Override
  Promise<List<User>> getUsers () {
    ExecControl.current ().promiseOf (storage)
  }
}

我认为将ExecControl的行改为：

Promise.of (storage)

会起作用，但会导致

MissingMethodException: No signature of method: static ratpack.exec.Promise.of() is applicable for argument types: (java.util.ArrayList).

Promise.of（）方法需要一种类型的ratpack.exec.Upstream.

应该如何修改上面的DefaultUserService类以使用Ratpack v1.1.1？

Answer 1

Promise.of(Upstream)http://ratpack.io/manual/current/api/ratpack/exec/Promise.html#of-ratpack.exec.Upstream-是一种向下游消费者发送某个过程的结果信号的方式。您可以通过Downstream#error(Throwable)或Downstream#success(value)发出是否成功完成的信号http://ratpack.io/manual/current/api/ratpack/exec/Downstream.html

您也可以通过Promise.value(value) 从已知值创建Promise

除了Promise之外，Ratpack还提供了ratpack.exec.Operation，它与Promise<Void>类似，表示无返回类型的异步工作。

我整理了一个示例来演示创建异步工作表示的各种方法。

@Grab('io.ratpack:ratpack-groovy:1.1.1')
import ratpack.exec.Operation
import ratpack.exec.Promise
import ratpack.handling.Context
import ratpack.jackson.Jackson
import static ratpack.groovy.Groovy.ratpack
class User { String name }
class UserService {
    private final List<User> storage = []
    Operation save(User user) {
        storage << user
        Operation.noop()
    }
    Promise<List<User>> getUsers() {
        Promise.of { downstream -> downstream.success(storage) }
        // or
//      Promise.value(storage)
    }
}
ratpack {
    bindings {
        bindInstance new UserService()
    }
    handlers {
        get { Context ctx, UserService userService ->
            userService.getUsers()
                    .map(Jackson.&json)
                    .then(ctx.&render)
        }
        get('add/:name') { UserService userService ->
            userService.save(new User(name: pathTokens.get('name')))
                    .then { render 'User saved' }
        }
    }
}

以下是我针对以下内容执行的一些示例curl命令：

$ curl localhost:5050
[]
$ curl localhost:5050/add/dan
User saved
$ curl localhost:5050/
[{"name":"dan"}]
$ curl localhost:5050/add/luke
User saved
$ curl localhost:5050/
[{"name":"dan"},{"name":"luke"}]