reactive-async

reactive-async copied to clipboard

[minor] Add pool.onQuiescent(cell)

1

Fixes #89 (but see discussion at #89 )

JanKoelzer

Add "Smart Progagation Prevention"

1

JanKoelzer

Check monotonicity of whenNext callback

1

For whenNext without threshold, results must always increase, if input increases. This has to be checked at runtime. Use a table to store previous inputs/outputs. Use #86 on a new...

JanKoelzer

After merging #107 , there seems to be no use for `whileQuiescentResolveCell` and `whileQuiescentResolveDefault`.

JanKoelzer

Several tests generate very suspicious output, but don't fail

4

When running the test suite (w.r.t. master or including the proposed changes in PR #40) core/test, I get messages such as: > problem with cell.CellImpl@744a46be; existing value: Success(20), new value:...

Delors

Enforce correct pool for cells

1

- Cells should not run in the "wrong" HandlerPool. - Cells that depend on each other must be in the same HandlerPool. - Rename to HandlerContext. See https://gist.github.com/phaller/a4fade7906bad95a61f24311ace62d66 for details.

JanKoelzer

Add Pool.onQuiescent(Cell)

2

pool.onQuiescent(cell) {v => …} Or maybe use Cell.getResult(): Future[V]? This could return if putFinal has been called but pool is still running.

JanKoelzer

Add whenNext with threshold

1

- The callback will be triggered at most once. - Thresholds must be pairwise incompatible. (Check at runtime.)

JanKoelzer

Calls of whenNext/whenComplete should be stalled until init() returns. Notes: - Maybe on can reuse Cell.tasksActive to track, if init() has returned. - Maybe State.deps could be used as Map[otherCell,...

JanKoelzer

Add priorities to tasks/dependencies

1

We talked about adding priorities to tasks/dependencies to improve the performance of evaluations. NextCallbacks and CompleteCallbacks with a high priority should be called earlier. The implementation in https://github.com/JanKoelzer/reactive-async/tree/jan-prio-ThreadPoolExecutor uses a...

JanKoelzer