Tweet DB Data Source returning an Observable

TweetDao.kt

// query from the Tweet DAO, or DB data source
@Query("SELECT *
FROM ${Tweet.TABLE_NAME}
WHERE tweet_id IN(:tweetIds) ORDER BY created_at DESC")
fun retrieveAllTweetsForTweetsIdsRx(tweetIds: List<String>): 
Observable<List<Tweet>>