.sink の直前に .flatMap { lgtms in lgtms.publisher } みたいなのを挟んでフラットにするのはいかがでしょう？ (edited)