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 923eb86 commit b2fde42Copy full SHA for b2fde42
driver-scala/src/main/scala/org/mongodb/scala/internal/SingleItemObservable.scala
@@ -25,15 +25,18 @@ private[scala] case class SingleItemObservable[A](item: A) extends SingleObserva
25
new Subscription {
26
@volatile
27
private var subscribed: Boolean = true
28
+ @volatile
29
+ private var completed: Boolean = false
30
31
override def isUnsubscribed: Boolean = !subscribed
32
33
override def request(n: Long): Unit = {
34
require(n > 0L, s"Number requested must be greater than zero: $n")
35
- if (subscribed) {
36
+ if (subscribed && !completed) {
37
observer.onNext(item)
38
observer.onComplete()
39
+ completed = true
40
}
41
42
0 commit comments