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-reactiveThe high-level streams library
reactive reactive-library functional-reactive streamsNow you will have a stream-handbook command that will open this readme file in your $PAGER. Otherwise, you may continue reading this document as you are presently doing.Streams come to us from the earliest days of unix and have proven themselves over the decades as a dependable way to compose large systems out of small components that do one thing well. In unix, streams are implemented by the shell with | pipes. In node, the built-in stream module is used by the core libraries and can also be used by user-space modules. Similar to unix, the node stream module's primary composition operator is called .pipe() and you get a backpressure mechanism for free to throttle writes for slow consumers.
documentation guide handbook stream streamsA lightweight wrapper around SQLiteOpenHelper and ContentResolver which introduces reactive stream semantics to queries. SQL Brite's only responsibility is to be a mechanism for coordinating and composing the notification of updates to tables such that you can update queries as soon as data changes. This library is not an ORM. It is not a type-safe query mechanism. It won't serialize the same POJOs you use for Gson. It's not going to perform database migrations for you.
sql reactive pub-sub publish-subscribe streamsA 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 streamsEnhancing Java 8 Streams
java8 collections streams-api functional-programming functional streamsPowerful Streams and functional data types for building modern Java 8 applications. We extend JDK interfaces where possible for maximum integration.ReactiveSeq extends JDK Stream and offers multiple modes of execution - synchonous, asynchronous, asynchronous with backpressure, parallel and more.
functional-programming reactive-streams monoid streams collections data-structures monad monad-transformers reactive asynchronous java8 streams-apiEasy 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 pipeUse HTML5 websockets using the Node Streams API.This module works in Node or in Browsers that support WebSockets. You can use browserify to package this module for browser use.
websocket websockets stream streams realtimeicaro 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-watchHazelcast Jet is a distributed computing platform built for high-performance stream processing and fast batch processing. It embeds Hazelcast In-Memory Data Grid (IMDG) to provide a lightweight, simple-to-deploy package that includes scalable in-memory storage. Hazelcast Jet performs parallel execution to enable data-intensive applications to operate in near real-time.
in-memory data-grid big-data stream-processing data-processing real-time streams batch-processingVavr is an object-functional language extension to Java 8, which aims to reduce the lines of code and increase code quality. It provides persistent collections, functional abstractions for error handling, concurrent programming, pattern matching and much more.
javaslang java8 functional-programming object-functional immutable-collections persistent-collections vavr functional streams collections java-collectionspump.io is a stream server that does most of what people really want from a social network. You post anything and my followers see it. It is an alternative to twitter. You can post almost anything that can be represented with activity streams -- short or long text, bookmarks, images, video, audio, events, geo checkins. You can follow friends, create lists of people, and so on.
federation social-network decentralization social activitystreams streams api app-server social-networking twitter-alternativeZIO is a zero-dependency Scala library for asynchronous and concurrent programming. It is powered by highly-scalable, non-blocking fibers that never waste or leak resources, ZIO lets you build scalable, resilient, and reactive applications that meet the needs of your business.
concurrency asynchronicity functional-programming queues streams promises stm asynchronous concurrent concurrent-programming asynchronous-programming concurrent-data-structure
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.