We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6313ddd commit 086b578Copy full SHA for 086b578
src/main/scala/com/github/yruslan/channel/AsyncChannel.scala
@@ -94,21 +94,19 @@ class AsyncChannel[T](maxCapacity: Int) extends Channel[T] {
94
lock.lock()
95
try {
96
writers += 1
97
-
98
var isTimeoutExpired = false
99
while (!closed && !hasCapacity && !isTimeoutExpired) {
100
isTimeoutExpired = !awaitWriters(awaiter)
101
}
+ writers -= 1
102
103
- val isSucceeded = if (!closed && hasCapacity) {
+ if (!closed && hasCapacity) {
104
q.enqueue(value)
105
notifyReaders()
106
true
107
} else {
108
false
109
110
- writers -= 1
111
- isSucceeded
112
} finally {
113
lock.unlock()
114
0 commit comments