Skip to content

Implementation of the cancellable tasks queue using ZIO

Notifications You must be signed in to change notification settings

eugengarkusha/ZioTaskQueue

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

18 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

ZioTaskQueue

Implementation of the cancellable tasks queue using ZIO

Supported oprations:

  • add task by key. Returns the task result. Locks fiber until result is ready.
  • cancel task by key, supports label to identify the origin of the call. Returns the task cancellation result. Locks fiber until task is cancelled.
  • join task by key. Returns join result. Locks fiber until result is ready.
  • getRegisteredTaskKeys. Returns all keys of the tasks which are either in progress or registered for execution
  • add_ and cancel_ : versions of the respective operations which ignore the results. Return without waiting for completion.

Completion result types:

  • Done(result)
  • Cancelled(origin)
  • Failed(errors)
  • Died(defects)
  • Duplicate
  • Rejected

Cancellation/Join result types:

  • Done(result)
  • Cancelled(origin)
  • Failed(errors)
  • Died(defects)
  • NotFound

About

Implementation of the cancellable tasks queue using ZIO

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages