Constructor Detail

• FlushWorker

  FlushWorker(Context context, SuspendFunction4<String, String, ByteArray, Boolean, FlushAttemptResult> networkExecutor)

Method Detail

• start

  @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)