open200/xesar-connect

Add queryStream function and corresponding extension functions

Closed this issue · 0 comments

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>