Subscriber of Room's DAO method returning Flowable is not notified about inserted entities
I have a Room database with one entity and DAO, which allows inserting objects and observing SELECT query as Flowable. When I subscribe to this Flowable and, then, insert a new object to database, new results are not emmited.
@Database(entities = [User::class], version = 1)
abstract class TestDatabase : RoomDatabase() {
abstract val dao: UserDao
}
@Dao
interface UserDao {
@Insert
fun insert(user: User)
@Query("SELECT * FROM User")
fun observeUsers(): Flowable<List<User>>
}
@Entity
data class User(@PrimaryKey val id: Int, val name: String)
A failing test:
@RunWith(AndroidJUnit4::class)
class ObserveUsersTest {
@Test
fun observeUsersTest() {
val db = Room.inMemoryDatabaseBuilder(
InstrumentationRegistry.getContext(), TestDatabase::class.java
).build()
val dao = db.dao
val user = User(0, "George")
val test = dao.observeUsers().test()
dao.insert(user)
test.assertValue(listOf(user))
db.close()
}
}
The failure:
java.lang.AssertionError: Expected: [User(id=0, name=George)] (class: SingletonList), Actual: (latch = 1, values = 0, errors = 0, completions = 0)
Test passes if inserting is done before calling to observeUsers:
dao.insert(user)
dao.observeUsers().test().assertValue(listOf(user))
What am I doing wrong?
android rx-java2 android-room asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
add a comment |
I have a Room database with one entity and DAO, which allows inserting objects and observing SELECT query as Flowable. When I subscribe to this Flowable and, then, insert a new object to database, new results are not emmited.
@Database(entities = [User::class], version = 1)
abstract class TestDatabase : RoomDatabase() {
abstract val dao: UserDao
}
@Dao
interface UserDao {
@Insert
fun insert(user: User)
@Query("SELECT * FROM User")
fun observeUsers(): Flowable<List<User>>
}
@Entity
data class User(@PrimaryKey val id: Int, val name: String)
A failing test:
@RunWith(AndroidJUnit4::class)
class ObserveUsersTest {
@Test
fun observeUsersTest() {
val db = Room.inMemoryDatabaseBuilder(
InstrumentationRegistry.getContext(), TestDatabase::class.java
).build()
val dao = db.dao
val user = User(0, "George")
val test = dao.observeUsers().test()
dao.insert(user)
test.assertValue(listOf(user))
db.close()
}
}
The failure:
java.lang.AssertionError: Expected: [User(id=0, name=George)] (class: SingletonList), Actual: (latch = 1, values = 0, errors = 0, completions = 0)
Test passes if inserting is done before calling to observeUsers:
dao.insert(user)
dao.observeUsers().test().assertValue(listOf(user))
What am I doing wrong?
android rx-java2 android-room asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
add a comment |
I have a Room database with one entity and DAO, which allows inserting objects and observing SELECT query as Flowable. When I subscribe to this Flowable and, then, insert a new object to database, new results are not emmited.
@Database(entities = [User::class], version = 1)
abstract class TestDatabase : RoomDatabase() {
abstract val dao: UserDao
}
@Dao
interface UserDao {
@Insert
fun insert(user: User)
@Query("SELECT * FROM User")
fun observeUsers(): Flowable<List<User>>
}
@Entity
data class User(@PrimaryKey val id: Int, val name: String)
A failing test:
@RunWith(AndroidJUnit4::class)
class ObserveUsersTest {
@Test
fun observeUsersTest() {
val db = Room.inMemoryDatabaseBuilder(
InstrumentationRegistry.getContext(), TestDatabase::class.java
).build()
val dao = db.dao
val user = User(0, "George")
val test = dao.observeUsers().test()
dao.insert(user)
test.assertValue(listOf(user))
db.close()
}
}
The failure:
java.lang.AssertionError: Expected: [User(id=0, name=George)] (class: SingletonList), Actual: (latch = 1, values = 0, errors = 0, completions = 0)
Test passes if inserting is done before calling to observeUsers:
dao.insert(user)
dao.observeUsers().test().assertValue(listOf(user))
What am I doing wrong?
android rx-java2 android-room asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
I have a Room database with one entity and DAO, which allows inserting objects and observing SELECT query as Flowable. When I subscribe to this Flowable and, then, insert a new object to database, new results are not emmited.
@Database(entities = [User::class], version = 1)
abstract class TestDatabase : RoomDatabase() {
abstract val dao: UserDao
}
@Dao
interface UserDao {
@Insert
fun insert(user: User)
@Query("SELECT * FROM User")
fun observeUsers(): Flowable<List<User>>
}
@Entity
data class User(@PrimaryKey val id: Int, val name: String)
A failing test:
@RunWith(AndroidJUnit4::class)
class ObserveUsersTest {
@Test
fun observeUsersTest() {
val db = Room.inMemoryDatabaseBuilder(
InstrumentationRegistry.getContext(), TestDatabase::class.java
).build()
val dao = db.dao
val user = User(0, "George")
val test = dao.observeUsers().test()
dao.insert(user)
test.assertValue(listOf(user))
db.close()
}
}
The failure:
java.lang.AssertionError: Expected: [User(id=0, name=George)] (class: SingletonList), Actual: (latch = 1, values = 0, errors = 0, completions = 0)
Test passes if inserting is done before calling to observeUsers:
dao.insert(user)
dao.observeUsers().test().assertValue(listOf(user))
What am I doing wrong?
android rx-java2 android-room android rx-java2 android-room asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
edited Nov 16 '18 at 22:00
Piotr Aleksander Chmielowski
asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
asked Nov 16 '18 at 21:25
Piotr Aleksander ChmielowskiPiotr Aleksander Chmielowski
92611327
92611327
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
I'd guess you don't wait long enough to observe the result of the insertion. If insert is asynchronous internally (even though you didn't define it with an RxJava API), you could be subscribing and testing for a single value too early.
Try using the awaitCount tester-method before asserting a single value (as you have a infinite Flowable so awaitTerminalEvent doesn't work of course):
dao.observeUsers()
.test()
.awaitCount(1, TestWaitStrategy.SLEEP_10MS, 5000)
.assertValue(listOf(user));
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
add a comment |
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53345599%2fsubscriber-of-rooms-dao-method-returning-flowable-is-not-notified-about-inserte%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
I'd guess you don't wait long enough to observe the result of the insertion. If insert is asynchronous internally (even though you didn't define it with an RxJava API), you could be subscribing and testing for a single value too early.
Try using the awaitCount tester-method before asserting a single value (as you have a infinite Flowable so awaitTerminalEvent doesn't work of course):
dao.observeUsers()
.test()
.awaitCount(1, TestWaitStrategy.SLEEP_10MS, 5000)
.assertValue(listOf(user));
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
add a comment |
I'd guess you don't wait long enough to observe the result of the insertion. If insert is asynchronous internally (even though you didn't define it with an RxJava API), you could be subscribing and testing for a single value too early.
Try using the awaitCount tester-method before asserting a single value (as you have a infinite Flowable so awaitTerminalEvent doesn't work of course):
dao.observeUsers()
.test()
.awaitCount(1, TestWaitStrategy.SLEEP_10MS, 5000)
.assertValue(listOf(user));
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
add a comment |
I'd guess you don't wait long enough to observe the result of the insertion. If insert is asynchronous internally (even though you didn't define it with an RxJava API), you could be subscribing and testing for a single value too early.
Try using the awaitCount tester-method before asserting a single value (as you have a infinite Flowable so awaitTerminalEvent doesn't work of course):
dao.observeUsers()
.test()
.awaitCount(1, TestWaitStrategy.SLEEP_10MS, 5000)
.assertValue(listOf(user));
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
I'd guess you don't wait long enough to observe the result of the insertion. If insert is asynchronous internally (even though you didn't define it with an RxJava API), you could be subscribing and testing for a single value too early.
Try using the awaitCount tester-method before asserting a single value (as you have a infinite Flowable so awaitTerminalEvent doesn't work of course):
dao.observeUsers()
.test()
.awaitCount(1, TestWaitStrategy.SLEEP_10MS, 5000)
.assertValue(listOf(user));
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
answered Nov 17 '18 at 17:17
akarnokdakarnokd
49.4k9102150
49.4k9102150
add a comment |
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53345599%2fsubscriber-of-rooms-dao-method-returning-flowable-is-not-notified-about-inserte%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
