174 best open source streams projects.

We have collection of more than 1 Million open source products ranging from Enterprise product to small libraries in all platforms. We aggregate information from all open source repositories. Search and find the best for your needs. Check out projects section.

Displaying 1 to 20 from 174 results

most - Ultra-high performance reactive programming

Javascript

Monadic streams

reactive reactive-programming reactive-streams stream streams event-stream promise promises promises-aplus fantasy-land monad monadic functional async cujojs cujo

asynquence - Asynchronous flow control (promises, generators, observables, CSP, etc)

Javascript

promise-style async sequence flow-control

async flow-control promises generators observables csp streams async-programming async-await library sequences promise iterator generator

bacon.js - FRP (functional reactive programming) library for Javascript

CoffeeScript

A small functional reactive programming lib for JavaScript.

bacon.js bacon frp functional reactive programming stream streams eventstream rx rxjs observable reactive-library functional-reactive

mobx - Simple, scalable state management.

Javascript

Simple, scalable state management.

mobx reactive-programming react typescript mobservable observable react-component reactjs reactive model frp functional-reactive-programming state-management data-flow reactive-library functional-reactive streams

highland - High-level streams library for Node.js and the browser

Javascript

The high-level streams library

reactive reactive-library functional-reactive streams

execa - A better `child_process`

Javascript

Execute a file.Think of this as a mix of child_process.execFile and child_process.spawn.

nodejs spawn exec spawned-processes child-process shell execute binary streams child process fork execfile file bin binaries npm path local

stream-handbook - how to write node programs with streams

Javascript

Now 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 streams

Sqlbrite - A lightweight wrapper around SQLiteOpenHelper which introduces reactive stream semantics to SQL operations

Java

A 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 streams

htmlparser2 - forgiving html and xml parser

Javascript

A 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 atom

samsara - ☸️ Continuous UI

Javascript

Note: 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 samsara

vinyl-fs - Vinyl adapter for the file system.

Javascript

Vinyl 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 streams

streamex - Enhancing Java 8 Streams

Java

Enhancing Java 8 Streams

java8 collections streams-api functional-programming functional streams

cyclops-react - An advanced, but easy to use, platform for writing functional applications in Java 8

Java

Powerful 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-api

pump.io - Social server with an ActivityStreams API

Javascript

pump.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-alternative

through - simple way to create a ReadableWritable stream that works

Javascript

Easy 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 pipe

websocket-stream - websockets with the node stream API

Javascript

Use 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 realtime

icaro - Smart and efficient javascript object observer, ideal for batching DOM updates (~1kb)

Javascript

icaro 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-watch

Hazelcast Jet - A general purpose distributed data processing engine, built on top of Hazelcast.

Java

Hazelcast 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-processing

Vavr - Object-functional language extension to Java

Java

Vavr 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-collections

TymeacRSE - Java Reactive Streams Push Engine

Java

TymeacRSE is a Recursive Streams push engine for managing the publication and distribution of items to subscribers. An efficient push engine allowing (Reactive Stream) Publishers to generate asynchronous streams for routing to Subscribers. It provides an efficient multitasking service that allows many resource-intensive applications to coexist in a single microservice.

reactive-streams reactive streams push-engine asynchronous