Skip to content

Commit 56d1ff6

Browse files
Make unsubscribe idempotent.
1 parent b663a1d commit 56d1ff6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Subscription.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ object Subscription {
6464
def isUnsubscribed = unsubscribed.get()
6565

6666
val asJavaSubscription = new rx.Subscription {
67-
def unsubscribe() { u; unsubscribed.set(true) }
67+
def unsubscribe() { if(unsubscribed.get()) { u ; unsubscribed.set(true) }}
6868
}
6969
}
7070
}

0 commit comments

Comments
 (0)