funkia / purescript-hareactive Goto Github PK

Hello @paldepind
I think will be better to have another package for DOM-related constructions.
We should use FRP without DOM-related things.
That just my thoughts

It would be nice to have couple simple examples:

1. How to produce Stream from keyboard events. (Is there some "streamFromEvent" from hareactive counterpart?)
2. How to "subscribe" Stream to do some Effect.

Thx.

@erisco asked on the PureScript Slack wether or not runStreamAff runs Affs in parallel or sequentially. This made me realize that there is no way to control that currently. @limemloh and I have discussed it and this is what I propose.

We will have two ways of running Affs from streams. One, runStreamAff which runs effects in parallel and an alternative runStreamAffPar which takes an integer n specifying that only n threads may run in parallel. Then runStreamAff is essentially the same as runStreamAffPar Infinity and runStreamAffPar 1 runs the Affs completely sequentially.

These are the types:

runStreamAff :: forall a. Stream (Aff a) -> Now (Stream (Future (Either Error a)))
runStreamAffPar :: forall a. Int -> Stream (Aff a) -> Now (Future (Either Error a))

Unlike the current runStreamAff these delivers their result as Futures. To flatten and order these we will add the following functions:

joinFutures :: forall a. Stream (Future a) -> Stream a
joinFuturesLatest :: forall a. Stream (Future a) -> Stream a
joinFuturesOrdered :: forall a. Stream (Future a) -> Stream a

The first simply delivers the result as they come back, the second discards old results (what you want for the zip code example) and the last one delivers results in the same order that they came in, delaying results if some preceding Affs are slow.

Does this handle all the different orderings that one may want? What do you think @erisco?

Hello!

Currently, I have this thing in my code:

flattenArrayStream :: forall a. Stream (Array a) -> Now (Stream a)
flattenArrayStream input = do
  ss <- liftEffect sinkStream'
  liftEffect $ subscribe (foldMap (\x -> pushSink x ss.sink)) input
  pure ss.stream

Perhaps a new combinator that does something like this the "proper" way (perhaps without using Effect?) would be useful?