ShivamDev31

override fun clear(): Completable {
        return prefSubject.firstOrError()
                .clearSharedPreferences {
                    remove(KEY_NAME)
                }
    }

    fun Single<SharedPreferences>.clearSharedPreferences(batch: SharedPreferences.Editor.() -> Unit): Completable =
            flatMapCompletable {
                Completable.fromAction {

ShivamDev31

override fun name(): Observable<String> = prefSubject
            .map { it.getString(KEY_NAME, "") }

ShivamDev31

override fun saveName(name: String): Completable = prefSubject
                    .firstOrError()
                    .editSharedPreferences {
                        putString(KEY_NAME, name)
                    }

    fun Single<SharedPreferences>.editSharedPreferences(batch: SharedPreferences.Editor.() -> Unit): Completable =
            flatMapCompletable {
                Completable.fromAction {
                    it.edit().also(batch).apply()

ShivamDev31

private val prefSubject = BehaviorSubject.createDefault(preferences)

    private val prefChangeListener = SharedPreferences.OnSharedPreferenceChangeListener { sharedPreferences, _ ->
        prefSubject.onNext(sharedPreferences)
    }

    init {
        preferences.registerOnSharedPreferenceChangeListener(prefChangeListener)
    }

ShivamDev31

companion object {

        @JvmStatic
        fun create(context: Context): SharedPreferencesNameRepository {
            val preferences = context.getSharedPreferences("RxPrefs", Context.MODE_PRIVATE)
            return SharedPreferencesNameRepository(preferences)
        }

        private const val KEY_NAME = "key_name"

ShivamDev31

class SharedPreferencesNameRepository(preferences: SharedPreferences) : NameRepository {
    private val prefSubject = BehaviorSubject.createDefault(preferences)

    private val prefChangeListener = SharedPreferences.OnSharedPreferenceChangeListener { sharedPreferences, _ ->
        prefSubject.onNext(sharedPreferences)
    }

    companion object {

        @JvmStatic

ShivamDev31

interface NameRepository {

    fun saveName(name: String): Completable

    fun name(): Observable<String>

    fun clear(): Completable
}

ShivamDev31

private fun handleData() {
        bSubmit.setOnClickListener {
            val name = etName.text.toString()
            disposables.add(repository.saveName(name).subscribe())
        }

        disposables.add(repository.name().subscribe({
            tvName.text = it
        }, {
            Log.e("Error : ", "", it)

ShivamDev31

private lateinit var repository: NameRepository

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        repository = SharedPreferencesNameRepository.create(this)
        handleData()
    }

ShivamDev31

package com.newsuk.analytics

import android.app.Application
import android.os.Bundle
import com.krux.androidsdk.aggregator.KruxEventAggregator
import com.newsuk.rx.SchedulingStrategy
import com.newsuk.thesun.mobile.BuildConfig
import com.newsuk.thesun.mobile.advert.DeviceIdProvider

interface KruxConsentProvider {