Skip to content

Commit d7a0d85

Browse files
committed
Formatting
1 parent 32c2b33 commit d7a0d85

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

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

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,13 @@ object Channel {
218218
else (state.copy(waiting = waiting.some), state)
219219
}
220220
.flatMap {
221-
case s @ State(initValues, stateSize, ignorePreviousWaiting @ _, producers, closed) =>
221+
case s @ State(
222+
initValues,
223+
stateSize,
224+
ignorePreviousWaiting @ _,
225+
producers,
226+
closed
227+
) =>
222228
if (shouldEmit(s)) {
223229
var size = stateSize
224230
val tailValues = List.newBuilder[A]

0 commit comments

Comments
 (0)