File tree 1 file changed +0
-16
lines changed
kotlinx-coroutines-core/common/src/channels
1 file changed +0
-16
lines changed Original file line number Diff line number Diff line change @@ -122,22 +122,6 @@ internal abstract class AbstractSendChannel<E> : SendChannel<E> {
122
122
}
123
123
}
124
124
125
- /* *
126
- * @suppress **This is unstable API and it is subject to change.**
127
- */
128
- protected fun describeSendConflated (element : E ): AddLastDesc <* > = SendConflatedDesc (queue, element)
129
-
130
- private class SendConflatedDesc <E >(
131
- queue : LockFreeLinkedListHead ,
132
- element : E
133
- ) : SendBufferedDesc<E>(queue, element) {
134
- override fun finishOnSuccess (affected : LockFreeLinkedListNode , next : LockFreeLinkedListNode ) {
135
- super .finishOnSuccess(affected, next)
136
- // remove previous SendBuffered
137
- (affected as ? SendBuffered <* >)?.remove()
138
- }
139
- }
140
-
141
125
// ------ SendChannel ------
142
126
143
127
public final override val isClosedForSend: Boolean get() = closedForSend != null
You can’t perform that action at this time.
0 commit comments