Forgot to commit this
This commit is contained in:
parent
89a20be7ef
commit
67aafab46a
@ -4,6 +4,8 @@ import com.pushtorefresh.storio.sqlite.operations.get.PreparedGetListOfObjects
|
|||||||
import com.pushtorefresh.storio.sqlite.operations.get.PreparedGetObject
|
import com.pushtorefresh.storio.sqlite.operations.get.PreparedGetObject
|
||||||
import com.pushtorefresh.storio.sqlite.operations.put.PreparedPutCollectionOfObjects
|
import com.pushtorefresh.storio.sqlite.operations.put.PreparedPutCollectionOfObjects
|
||||||
import com.pushtorefresh.storio.sqlite.operations.put.PreparedPutObject
|
import com.pushtorefresh.storio.sqlite.operations.put.PreparedPutObject
|
||||||
|
import com.pushtorefresh.storio.sqlite.operations.put.PutResult
|
||||||
|
import com.pushtorefresh.storio.sqlite.operations.put.PutResults
|
||||||
import kotlinx.coroutines.Dispatchers
|
import kotlinx.coroutines.Dispatchers
|
||||||
import kotlinx.coroutines.withContext
|
import kotlinx.coroutines.withContext
|
||||||
|
|
||||||
@ -15,10 +17,10 @@ suspend fun <T> PreparedGetObject<T>.executeOnIO(): T? {
|
|||||||
return withContext(Dispatchers.IO) { executeAsBlocking() }
|
return withContext(Dispatchers.IO) { executeAsBlocking() }
|
||||||
}
|
}
|
||||||
|
|
||||||
suspend fun <T> PreparedPutObject<T>.executeOnIO() {
|
suspend fun <T> PreparedPutObject<T>.executeOnIO(): PutResult {
|
||||||
withContext(Dispatchers.IO) { executeAsBlocking() }
|
return withContext(Dispatchers.IO) { executeAsBlocking() }
|
||||||
}
|
}
|
||||||
|
|
||||||
suspend fun <T> PreparedPutCollectionOfObjects<T>.executeOnIO() {
|
suspend fun <T> PreparedPutCollectionOfObjects<T>.executeOnIO(): PutResults<T> {
|
||||||
withContext(Dispatchers.IO) { executeAsBlocking() }
|
return withContext(Dispatchers.IO) { executeAsBlocking() }
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user