subscribe

inline fun <T> subscribe(liveQueryId: String): Flow<LiveQueryAction<T>>