Skip to content

Commit 5f10d0b

Browse files
committed
reformat my change in ChannelFlow
1 parent 905fe0a commit 5f10d0b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

kotlinx-coroutines-core/common/src/flow/internal/ChannelFlow.kt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,8 @@ public abstract class ChannelFlow<T>(
114114
public open fun produceImpl(scope: CoroutineScope): ReceiveChannel<T> =
115115
produceImplInternal(scope, CoroutineStart.ATOMIC)
116116

117-
internal open fun produceImplInternal(scope: CoroutineScope, start: CoroutineStart): ReceiveChannel<T> = scope.produce(context, produceCapacity, onBufferOverflow, start = start, block = collectToFun)
117+
internal open fun produceImplInternal(scope: CoroutineScope, start: CoroutineStart): ReceiveChannel<T> =
118+
scope.produce(context, produceCapacity, onBufferOverflow, start = start, block = collectToFun)
118119

119120
override suspend fun collect(collector: FlowCollector<T>): Unit =
120121
coroutineScope {

0 commit comments

Comments
 (0)