```
public final class FlushWorker

                    
```
Watches for connectivity changes and flushes any cached requests using the provided networkExecutor. Caches requests using JSON Lines format.

Constructor Summary

Constructors
Constructor	Description
`FlushWorker(Context context, SuspendFunction4<String, String, ByteArray, Boolean, String> networkExecutor)`

Method Summary

Modifier and Type	Method	Description
`final Unit`	`start()`	Start listening and attempt an immediate flush on init.
`final Unit`	`stop()`	Stop the periodic flush timer.
`final Boolean`	`hasCachedRequests()`	Check if there are any cached requests remaining
`final Boolean`	`isProcessingCache()`	Check if cache processing is currently in progress
`final Unit`	`registerCompletionCallback(SuspendFunction0<Unit> callback)`	Register a callback to be notified when all cached requests are processed
`final Unit`	`cacheRequest(CachedRequest req)`	Append a failed request to the cache file as a single JSON line.
`final Unit`	`clearCache()`	Delete all cached requests immediately.
`final Unit`	`setPendingRequestsChecker(Function0<Boolean> checker)`	Set the callback to check for pending network requests
`final Boolean`	`hasPendingNetworkRequests()`	Check if there are pending network requests
`final Unit`	`applyConfig(Long flushIntervalSeconds, Integer batchSize)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - FlushWorker
```
FlushWorker(Context context, SuspendFunction4<String, String, ByteArray, Boolean, String> networkExecutor)
```
    Parameters:
    
    context - application context
    
    networkExecutor - a suspend func taking (method, route, jsonData) -> responseString?
- Method Detail
  - start
```
@RequiresApi(value = 23)@RequiresPermission(value = android.permission.ACCESS_NETWORK_STATE) final Unit start()
```
    Start listening and attempt an immediate flush on init.
  - stop
```
 final Unit stop()
```
    Stop the periodic flush timer.
  - hasCachedRequests
```
 final Boolean hasCachedRequests()
```
    Check if there are any cached requests remaining
  - isProcessingCache
```
 final Boolean isProcessingCache()
```
    Check if cache processing is currently in progress
  - registerCompletionCallback
```
 final Unit registerCompletionCallback(SuspendFunction0<Unit> callback)
```
    Register a callback to be notified when all cached requests are processed
  - cacheRequest
```
 final Unit cacheRequest(CachedRequest req)
```
    Append a failed request to the cache file as a single JSON line.
  - clearCache
```
 final Unit clearCache()
```
    Delete all cached requests immediately.
  - setPendingRequestsChecker
```
 final Unit setPendingRequestsChecker(Function0<Boolean> checker)
```
    Set the callback to check for pending network requests
  - hasPendingNetworkRequests
```
 final Boolean hasPendingNetworkRequests()
```
    Check if there are pending network requests
  - applyConfig
```
 final Unit applyConfig(Long flushIntervalSeconds, Integer batchSize)
```

Class FlushWorker

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

FlushWorker

Method Detail

start

stop

hasCachedRequests

isProcessingCache

registerCompletionCallback

cacheRequest

clearCache

setPendingRequestsChecker

hasPendingNetworkRequests

applyConfig