Add queryStream function and corresponding extension functions
Closed this issue · 0 comments
berka3 commented
Add queryStream function to provide a mechanism to fetch data from a query incrementally, in smaller chunks rather than retrieving all of it at once.
TODO:
- Add new queryStream function to XesarConnect
- Add new extension functions which use the queryStream function (all which implement the QueryListResource interface)
- Add tests
Function signature for queryStream:
internal inline fun <reified T : QueryListResource> queryStream( resource: String, params: Query.Params? = null, requestConfig: RequestConfig = buildRequestConfig() ): Flow<T>
Function signature for a Person:
fun queryPersonStream(): Flow<Person>