- feat: Consumer: adds StreamedStateConsumer with listener and builder
- fix: incorrect assertion on (Throttle/Debounce)DroppableConcurrency fixed
- feat: now you can create nullable state streams (Stream<State?>)
- fix: hide internal $setState from overriding
- feat: handler now can accept eventName that marks each event
- feat: StreamedObserver now have onEvent(Controller, String eventName)
-
BREAKING: StreamedController now uses custom handlers which passes into constructor (or directly into
super.eventHandler
) instead of mixinsBy default (if no handlers passed), StreamedController uses
ConcurrentConcurrencyHandler
-
feat: Observing: Introducing StreamedControllerObserver
-
feat: Custom Handling: create your own concurrency handlers based on
HandlerBase<State>
- feat: SequentalConcurrency mixin using AsyncQueue
- feat: ThrottledDroppableConcurrencyHandler can be awaited until throttle end
- refactor: reorganized package structure
- inner_fix: file signing (myself and author of selector feature)
- feat: any event (on
DroppableConcurrencyHandler
and it descendants) can be awaited as future (until stream finishes working) - fix: copyrighting in README.md
- feat:
DroppableConcurrencyHandler, DebouncedDroppableConcurrencyHandler, ThrottleDroppableConcurrencyHandler, RestartableConcurrencyHandler
- test: async increment stat, restartable test, concurrent test
- example: async counter example