hyundeeeee:DatabaseCreator.kt 변환

[hyunji92]

No description provided.

[ganadist]

val sInstance by lazy { DatabaseCreator()}
synchronized fun getInstance() = sInstance
// 다 없엔다

[ganadist]

fun createDb(context: Context) {

    Log.d("DatabaseCreator", "Creating DB from " + Thread.currentThread().name)

    if (!mInitializing.compareAndSet(true, false)) return  // Already initializing

    mIsDatabaseCreated.value = false // Trigger an update to show a loading screen.

    object : AsyncTask<Context, Void, Void>() {

        override fun doInBackground(vararg params: Context): Void? {
            Log.d("DatabaseCreator",
                    "Starting bg job " + Thread.currentThread().name)

            val context = params[0].applicationContext.apply {
                deleteDatabase(DATABASE_NAME)   // Reset the database to have new data on every run.
            }

            // Build the database!
            val db = Room.databaseBuilder<AppDatabase>(context.applicationContext,
                    AppDatabase::class.java, DATABASE_NAME).build()

            // Add a delay to simulate a long-running operation
            addDelay()

            // Add some data to the database
            DatabaseInitUtil.initializeDb(db)
            Log.d("DatabaseCreator",
                    "DB was populated in thread " + Thread.currentThread().name)

            database = db
            return null
        }

        override fun onPostExecute(ignored: Void) {
            // Now on the main thread, notify observers that the db is created and ready.
            mIsDatabaseCreated.value = true
        }
    }.execute(context.applicationContext)
}

[ganadist]

mIsDatabaseCreated.value = false// Trigger an update to show a loading screen.
Observable.just(context.applicationContext)
.subscribeOn(Schedulers.io())
.doOnNext{it.deleteDatabase(DATABASE_NAME)}
.map { Room.databaseBuilder(it,
AppDatabase::class.java, DATABASE_NAME).build() }
.doOnNext{
addDelay()
DatabaseInitUtil.initializeDb(it)
database = it
}
.observeOn(AndroidSchedulers.mainThread())
.subscribe { mIsDatabaseCreated.value = true }