promise-style async sequence flow-control
async flow-control promises generators observables csp streams async-programming async-await library sequences promise iterator generatorA small functional reactive programming lib for JavaScript.
bacon.js bacon frp functional reactive programming stream streams eventstream rx rxjs observable reactive-library functional-reactiveA forgiving HTML/XML/RSS parser. The parser can handle streams and provides a callback interface. A live demo of htmlparser2 is available here.
html-parser dom html parser streams xml rss feed atomNote: This project is not being developed further at the moment. I hope to return to it soon. SamsaraJS is a library for building continuous user interfaces. A continuous UI is one where many visual elements are animating in coordinated ways. For example, you may want to fade the opacity of a nav bar while a settings menu is translated by a user's swipe gesture. Or maybe you want to blur and scale a banner image when a user scrolls some content past its limits, and add a springy bounce at the end.
css3 layout html5 ui reactive streams frp samsaraVinyl adapter for the file system. Vinyl is a very simple metadata object that describes a file. When you think of a file, two attributes come to mind: path and contents. These are the main attributes on a Vinyl object. A file does not necessarily represent something on your computer’s file system. You have files on S3, FTP, Dropbox, Box, CloudThingly.io and other services. Vinyl can be used to describe files from all of these sources.
gulp vinyl-adapter vinyl file file-system fs streamsMobX is a battle tested, simple and scalable state management library transparently applying functional reactive programming (TFRP). The Mobx design principle is very simple: Anything that can be derived from the application state, should be derived. Automatically. This includes the UI, data serialization, server communication, etc.
mobx reactive-programming react typescript mobservable observable react-component reactjs reactive model frp functional-reactive-programming state-management data-flow reactive-library functional-reactive streamsEasy way to create a Stream that is both readable and writable.This function is the basis for most of the synchronous streams in event-stream.
stream streams user-streams pipeicaro is really fast compared to the other reactive libs because it smartly throttles all the state changes. icaro will let you listen to all the changes happening in a javascript object or array, grouping them efficiently, and optimizing the performance of your listeners.
observable proxy object object-listener object-observer streams object-observable object-watchTailor assembles a web page from multiple fragments
tailor layout-service streams mosaic microservice nodejs streaming-templates node-tailorpump is a small node module that pipes streams together and destroys all of them if one of them closes.When using standard source.pipe(dest) source will not be destroyed if dest emits close or an error. You are also not able to provide a callback to tell when then pipe has finished.
streams pipe destroy callbackStreamSaver.js is the solution to saving streams on the client-side. It is perfect for webapps that need to save really large amounts of data created on the client-side, where the RAM is really limited, like on mobile devices.There is not any magical saveAs() function that saves a stream, file or blob. The way we mostly save Blobs/Files today is with the help of a[download] attribute FileSaver.js takes advantage of this and create a convenient saveAs(blob, filename) function, very fantastic, but you can't create a objectUrl from a stream and attach it to a link...
stream service-worker filesaver ram html5 saving streams file blob download saveasExplore Node.js streams with an interactive playground. The Node.js Stream Playground was created to help Node.js developers better understand how streams work by showing a number of use cases that are easily plug-and-play-able. Additionally detailed logging is provided at every step to help users better understand what events the streams are emitting and exactly what their contents are.
stream streamsA small collection of Stream utilities for Java 8. Protonpack provides takeWhile, takeUntil, skipWhile, skipUntil, zip, zipWithIndex, unfold, MapStream, aggregate, Streamable, unique collector.
functional-programming functional streams utilitiesTo use bionode as a command line tool, you can install it globally with -g. Or, if you want to use it as a JavaScript library, you need to install it in your local project folder inside the node_modules directory by doing the same command without -g.
bionode tools metapackage bioinformatics nodejs os4openscience bio biology genomics genetics dna streams util server client browserLazypipe allows you to create an immutable, lazily-initialized pipeline. It's designed to be used in an environment where you want to reuse partial pipelines, such as with gulp. This module returns a function that can be used to start building a lazypipe. Individual steps are added via the .pipe() method. At any point, a new lazypipe can be built by adding to an existing one, without affecting the previous lazypipe. Lazypipes can even be used as steps within another lazypipe.
gulpfriendly stream streams combine lazy pipeline gulpRxJS Bindings for Node.js and io.js
rx rxjs eventemitter streams reactive
We have large collection of open source products. Follow the tags from
Tag Cloud >>
Open source products are scattered around the web. Please provide information
about the open source projects you own / you use.
Add Projects.