Overworked Cell::lift(s) about sodium-typescript

[clinuxrulz]

Here is one possible coalesce-free solution that will cause the lambda in the example above to be just evaluated twice:
https://gist.github.com/clinuxrulz/1bd47cda980cc256bd012506af268e54

It should be possible to eliminate Stream::coalesce_() from everything and thus remove the requirement of seq in Entry. It would allow everything with the same rank to be updated in parallel with threads or web-workers (if we want to). And it would decrease the size of the priority queue to the number of unique ranks being fired at once. (Each element of the priority queue being a list of entries of same rank.)

[jam40jeff]

This may cut down the number of times f can be called to be 2, but wouldn't it cause the next downstream listener to potentially see 2 values (and thus an intermediate value) since out is no longer coalesced?

EDIT: Never mind, I see that out.Send is properly prioritized (and prioritize will only be called once because of the pumping variable). This looks like a good optimization! Thanks.

[clinuxrulz]

Just Stream::merge and Cell::switchC to go before we are coalesce-free.

[jam40jeff]

Great! I'll have to look at making these changes to the .NET versions as well.

[clinuxrulz]

coalesce-free Stream::merge: https://gist.github.com/clinuxrulz/a06eba0d727a372b0016d19783f067fc

Its pretty much the same solution used for Cell::apply

Cell::switchC will need a little more thought.

[clinuxrulz]

coalesce-free Cell::switchC: https://gist.github.com/clinuxrulz/9f1bf3eafb38085517cb96d67522a84b

we can now live without seq in Entry.

[clinuxrulz]

I have an experimental branch that never resorts the priority queue with all tests passing. Not sure what the performance is like compared to the original though, so I will not PR until I've done more testing.

https://github.com/clinuxrulz/sodium-typescript/tree/priority-queue

[clinuxrulz]

Actually not confident in the switchC solution yet, will need to double check.

[clinuxrulz]

switchC all good now, found a missing pump() when debugging by doing random sort of entries of same rank.