* Events: type Batcher value & ensure queue order
Update Batcher to allow for typed value types.
Update Batcher and Queue to execute values in order they were added.
Signed-off-by: joshvanl <me@joshvanl.dev>
* Delay batcher to ensure key is sent in order
Signed-off-by: joshvanl <me@joshvanl.dev>
---------
Signed-off-by: joshvanl <me@joshvanl.dev>
* events/batcher: use events/queue as queue backend
Signed-off-by: joshvanl <me@joshvanl.dev>
* Make events/queue/queue key type comparable
Signed-off-by: joshvanl <me@joshvanl.dev>
* Explicitly define NewProcessor generic type in test
Signed-off-by: joshvanl <me@joshvanl.dev>
---------
Signed-off-by: joshvanl <me@joshvanl.dev>
* Update fswatcher to use /events/batcher
Signed-off-by: joshvanl <me@joshvanl.dev>
* Linting
Signed-off-by: joshvanl <me@joshvanl.dev>
* Linting
Signed-off-by: joshvanl <me@joshvanl.dev>
* Add sleep to wait for windows fsnotify to become ready
Signed-off-by: joshvanl <me@joshvanl.dev>
* Increase time for event to be received to 1 second
Signed-off-by: joshvanl <me@joshvanl.dev>
---------
Signed-off-by: joshvanl <me@joshvanl.dev>
* Bring in fswatcher from dapr/dapr
Also improved batching and error handling, and added unit tests
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Fixed resetting batchCh and added test
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Added missing copyright header
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Josh van Leeuwen
Alessandro (Ale) Segala