Mastodon/nextpush-android
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use AtomicRef for syncSource

Browse Source
This commit is contained in:
sim 2023-08-31 01:36:08 +02:00
parent a8abc9d9e5
commit d293129df5
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
app/src/main/java/org/unifiedpush/distributor/nextpush/api/Api.kt
View File

@ -18,6 +18,7 @@ import org.unifiedpush.distributor.nextpush.api.provider.* // ktlint-disable no-
import org.unifiedpush.distributor.nextpush.api.provider.ApiProvider.Companion.mApiEndpoint
import org.unifiedpush.distributor.nextpush.api.response.ApiResponse
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicReference
class Api(val context: Context) {
@ -35,8 +36,7 @@ class Api(val context: Context) {
fun apiDestroy() {
Log.d(TAG, "Destroying API")
syncSource?.cancel()
syncSource = null
syncSource.getAndSet(null)?.cancel()
}
fun apiSync() {
@ -91,7 +91,12 @@ class Api(val context: Context) {
.get()
.build()
syncSource = EventSources.createFactory(client).newEventSource(request, SSEListener(context.applicationContext))
syncSource.set(
EventSources.createFactory(client).newEventSource(
request,
SSEListener(context.applicationContext)
)
)
Log.d(TAG, "cSync done.")
}
@ -205,6 +210,6 @@ class Api(val context: Context) {
}
companion object {
private var syncSource: EventSource? = null
private val syncSource: AtomicReference<EventSource?> = AtomicReference(null)
}
}