Skip to content

Commit 32c2b33

Browse files
committed
Clarify variable names
1 parent 496bf02 commit 32c2b33

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

core/shared/src/main/scala/fs2/concurrent/Channel.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -218,19 +218,19 @@ object Channel {
218218
else (state.copy(waiting = waiting.some), state)
219219
}
220220
.flatMap {
221-
case s @ State(values, stateSize, ignorePreviousWaiting @ _, producers, closed) =>
221+
case s @ State(initValues, stateSize, ignorePreviousWaiting @ _, producers, closed) =>
222222
if (shouldEmit(s)) {
223223
var size = stateSize
224-
val moreValues = List.newBuilder[A]
224+
val tailValues = List.newBuilder[A]
225225
var unblock = F.unit
226226

227227
producers.foreach { case (value, producer) =>
228228
size += 1
229-
moreValues += value
229+
tailValues += value
230230
unblock = unblock <* producer.complete(())
231231
}
232232

233-
val toEmit = makeChunk(values, moreValues.result(), size)
233+
val toEmit = makeChunk(initValues, tailValues.result(), size)
234234

235235
unblock.as(Pull.output(toEmit) >> consumeLoop)
236236
} else {

0 commit comments

Comments
 (0)