Using initial value of observable in subscription along with the mapped one

Take a look at the following code snippet:

vertx.eventBus().consumer<JsonObject>(CREATEMEETING_SERVICE_ID).toObservable()
                .map { objectMapper.readValue(it.body().getJsonObject("body").encode(), Meeting::class.java) }
                .flatMap (meetingService::createMeeting)
                .subscribe(
                        { Json.encodePrettily(it) },
                        { throw it }
                )

I need to call message.reply method from the initial observable in onNext method of subscribe. One way of doing this is to use Pairs of rather than Meeting alone what makes this ugly. Is there any other option to make this work not having to use Pairs?

I know one more way which is like this:

vertx.eventBus().consumer<JsonObject>(CREATEMEETING_SERVICE_ID).toObservable()
                .subscribe { 
                    message ->
                        Observable.just(objectMapper.readValue(message.body().getJsonObject("body").encode(), Meeting::class.java))
                                .flatMap(meetingService::createMeeting)
                                .subscribe(
                                        { message.reply(Json.encodePrettily(it)) },
                                        { throw it }
                                )
                }

But it also looks wrong.

Maybe it also explains the problem.