bufferIntrospective emits at most Platform.recommendedBatchSize elements

[Jasper-M]

The documentation says:

Buffers signals while busy, after which it emits the buffered events as a single bundle.

But in fact it emits at most 1024 elements at a time on the JVM, keeping the excess elements in the buffer.

scala> @volatile var count = 0
var count: Int = 0

scala> Observable.repeatEvalF(Task{count += 1})
     |   .bufferIntrospective(5000)
     |   .take(5)
     |   .mapEval(buffer => Task.sleep(2.seconds) >> Task(println(s"got ${buffer.size} elements")))
     |   .completedL
     |   .runSyncUnsafe()
got 177 elements
got 333 elements
got 1024 elements
got 1024 elements
got 1024 elements

scala> count
val res27: Int = 8193