Как автоматически подписаться на внутренний Flux/Mono?

У меня есть поток (ограниченный) Flux, который я хочу преобразовать в поток Long, где Long — это размер внутреннего потока:

   Flux.just( Flux.just(1, 2, 3),  Flux.just(1, 2)  )
       .map(Flux::count)
       .log()
       .subscribe();

Журнал выполнения следующий:

onSubscribe([Synchronous Fuseable] FluxArray.ArraySubscription)
request(unbounded)
onNext({ "operator" : "Count" })
onNext({ "operator" : "Count" })
onComplete()

Flux::count возвращает Mono, а не Long. Есть ли операторы для автоматической распаковки этого внутреннего моно при подписке на основной поток?