No completions returned in the middle of the select chain

[kasiaMarek]

Reproduction steps

//> using scala 2.13.12
//> using dep com.github.fd4s:fs2-kafka_2.13:1.11.0

import scala.concurrent.ExecutionContext
import cats.effect._
import fs2.kafka._

object TopicListener {
    implicit val cs = IO.contextShift(ExecutionContext.global)
    implicit val timer = IO.timer(ExecutionContext.global)
    val x = KafkaConsumer.stream(null.asInstanceOf[ConsumerSettings[IO, String, String]])
       .subscribeTo("asdasd")
       .@@  // 1 <- no completions here
       .records
       .@@  // 2 <- everything is fine
}

Problem

An empty list of completions is returned.

Here is the original issue in metals: scalameta/metals#5984