CommandsTest.java 文件源码

EmailAnswer submitEmailHelper(String email, String platform, int workerID, Consumer<Context> responseVerifier) throws Exception {
    return submit(communication -> {
                when(communication.submitWorker(email, platform, LinkedListMultimap.create())).thenReturn(CompletableFuture.completedFuture(workerID));
            },
            context -> {
                when(context.getPathTokens().get("platform")).thenReturn(platform);
                Email build = Email.newBuilder().setEmail(email).build();
                TypedData data = mock(TypedData.class);
                try {
                    when(data.getText()).thenReturn(printer.print(build));
                } catch (InvalidProtocolBufferException e) {
                    throw new RuntimeException(e);
                }
                when(context.getRequest().getBody()).thenReturn(Promise.value(data));
            },
            Commands::submitEmail,
            responseVerifier
    );
}