File tree Expand file tree Collapse file tree 2 files changed +6
-6
lines changed
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/subscriptions Expand file tree Collapse file tree 2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -29,17 +29,17 @@ object SerialSubscription {
29
29
class SerialSubscription private [scala] (val asJavaSubscription : rx.subscriptions.SerialSubscription )
30
30
extends Subscription {
31
31
32
- private val _isUnsubscribed = new AtomicBoolean (false )
32
+ private val unsubscribed = new AtomicBoolean (false )
33
33
34
34
/**
35
35
* Checks whether the subscription has been unsubscribed.
36
36
*/
37
- def isUnsubscribed : Boolean = _isUnsubscribed .get()
37
+ def isUnsubscribed : Boolean = unsubscribed .get()
38
38
39
39
/**
40
40
* Unsubscribes this subscription, setting isUnsubscribed to true.
41
41
*/
42
- override def unsubscribe (): Unit = { super .unsubscribe(); _isUnsubscribed .set(true ) }
42
+ override def unsubscribe (): Unit = { super .unsubscribe(); unsubscribed .set(true ) }
43
43
44
44
def subscription_= (value : Subscription ): Unit = asJavaSubscription.setSubscription(value.asJavaSubscription)
45
45
def subscription : Subscription = Subscription (asJavaSubscription.getSubscription)
Original file line number Diff line number Diff line change @@ -65,11 +65,11 @@ object Subscription {
65
65
def apply (u : => Unit ): Subscription = {
66
66
new Subscription () {
67
67
68
- private val _isUnsubscribed = new AtomicBoolean (false )
69
- def isUnsubscribed = _isUnsubscribed .get()
68
+ private val unsubscribed = new AtomicBoolean (false )
69
+ def isUnsubscribed = unsubscribed .get()
70
70
71
71
val asJavaSubscription = new rx.Subscription {
72
- def unsubscribe () { u; _isUnsubscribed .set(true ) }
72
+ def unsubscribe () { u; unsubscribed .set(true ) }
73
73
}
74
74
}
75
75
}
You can’t perform that action at this time.
0 commit comments