BuckleScript bindings for Most.js.
In Reason:
let add = (x, y) => x + y;
let isEven = x => x mod 2 === 0;
Most.(
fromList([0, 1, 2, 3, 4, 5, 6, 7, 8])
|> map(add(2))
|> filter(isEven)
|> observe(x => Js.log(x))
|> Js.Promise.then_((_) => {
Js.log("Stream completed");
Js.Promise.resolve();
})
);
/**
* Logs:
* 2
* 4
* 6
* 8
* 10
* Stream completed
**/An example of implementing the Redux architecture in a ReasonReact project can be seen here.
Inside of a BuckleScript project:
npm install --save bs-most
Then add bs-most to your bs-dependencies in bsconfig.json:
{
...
"bs-dependencies": [
"bs-most"
]
}
The Most.js API docs are probably the best source of information about each method. This library attempts to provide very low-level bindings, except for what's noted in the What's different section.
The bindings are a single file in src/most.re. I try to provide comments next to each binding and am working on flushing out tests so that users can refer to them.
I am also available by e-mail or DM on the Reason discord (username: @lilactown).
generate- Reason doesn't have generator support yettransduce- Awkward to use in Reason/OCaml without a solid transducer impl (maybe coming soon?? 😉)combineArray- the callback for this is variadic (depending on how many streams you have in the array), not sure how to type it yet 😞
- Predicates that normally return "truthy" values, now only accept returning booleans
sampleis variadic so we offersample1,sample2,sample3...sample6fromEvent- DOM events are supported, but genericEventEmitter's are not yetfromonly works on arrays right now; generic iterators must be coercedfromListis a function that creates a stream from a ReasonListtype, e.g.fromList([1, 2, 3])unfoldis modeled a bit differently - instead of taking in a JS object{ done, value, seed }, it takes anoption (value, seed). Example:
/* emits 2,4,6 then completes */
Most.unfold(
(seed) =>
if (seed < 4) {
let nextSeed = seed + 1;
Some((seed * 2, nextSeed));
} else {
None;
},
1
);This library also includes some bindings for Subjects. Subjects are very useful for e.g. implementing a state store/dispatch system. The API is a little bit different from the raw most-subject library:
Subject.make: creates an asynchronous SubjectSubject.asStream: casts a subject to a stream, to be used by the rest of theMostmoduleSubject.next: emits a value on a subjectSubject.error: emits an error on a subjectSubject.complete: completes a subject with no valueSubject.completeWith: completes a subject with a value
npm run build
npm run watch
npm run test
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent