io.vertx.reactivex.core.eventbus.EventBus.rxSend()方法具有以下签名：
public <T> Single<Message<T>> rxSend(String address,
Object message,
DeliveryOptions options)
模拟它以返回包含真实对象的Single的正确方法是什么？问题是Message类除了一个接受另一个Message对象的构造函数之外没有构造函数。 因此，以下内容将编译：
Mockito.when(eventBus.rxSend(Mockito.isA(String.class),
Mockito.isA(JsonObject.class),
Mockito.isA(DeliveryOptions.class))).thenReturn(Single.just(new Message<Object>(null)));
但是当然Single.just(new Message<Object>(null))不包含一个真实的对象，然后可以传递该对象以测试顶点中的下一个处理程序。
谢谢
就像我在评论中提到的，我没有回答你的直接问题，但我想推荐一种不同的方法来获得你正在寻找的结果。
出于各种原因，通常不鼓励嘲笑您不拥有的类型。 最能引起我共鸣的两个(因为我是受害者(是：
- 如果模拟依赖项的实际实现发生变化，模拟的行为不会自动显示任何前向更改。 测试
- 引入的模拟越多，测试携带的认知负荷就越大。 有些测试需要大量的模拟才能工作。
有很多关于该主题的文章，其中包含更详细的观点和意见。 如果您有兴趣，请参考Mockito维基，或者只是谷歌。
鉴于所有这些，与其嘲笑EventBus，为什么不使用实际实例并接收由框架组成的Messages的真实回复？ 当然，严格来说，这更像是一个集成测试而不是单元测试，但更接近你想要的测试类型。
这是我在现有项目中编写的测试的示例片段，其中包含一些添加的注释。(该代码引用了一些带有 -"Ext" 后缀的非标准类型，但它们对该方法并不突出(。
private EventBus eventBus;
@Before
public setUp(@NotNull TestContext context) {
eventBus = Vertx.vertx().eventBus()
}
@Test
public void ping_pong_reply_test(@NotNull TestContext context) {
final Async async = context.async();
// the following is a MessageConsumer registered
// with the EventBus for this specific test.
// the reference is retained so that it can be
// "unregistered()" upon completion of this test
// so as not to affect other tests.
final MessageConsumer<JsonObject> consumer = eventBus.consumer(Ping.class.getName(), message -> {
// here is where you would otherwise place
// your mock Message generation.
MessageExt.replyAsJsonObject(message, new Pong());
});
final Ping message = new Ping();
final DeliveryOptions options = null;
// the following uses an un-mocked EventBus to
// send an event and receive a real Message reply.
// created by the consumer above.
EventBusExt.rxSendJsonObject(eventBus, message, options).subscribe(
result ->
// result.body() is JSON that conforms to
// the Pong type
consumer.unregister();
async.complete();
},
error -> {
context.fail(error);
}
);
}
我希望这至少能激发一些围绕你的问题的新思维。