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.
https://square.github.io/sqlbrite/3.x/sqlbrite/Tags | sql reactive pub-sub publish-subscribe streams |
Implementation | Java |
License | Apache |
Platform | OS-Independent |
Faye is a set of tools for simple publish-subscribe messaging between web clients. It ships with easy-to-use message routing servers for Node.js and Rack applications, and clients that can be used on the server and in the browser. It is based on the Bayeux protocol.
pub-sub messaging message-queue publish-subscribe bayeuxPubSubJS is a topic-based publish/subscribe library written in JavaScript. PubSubJS has synchronisation decoupling, so topics are published asynchronously. This helps keep your program predictable as the originator of topics will not be blocked while consumers process them.
pub/sub pubsub publish/subscribe publish subscribeMist is a simple pub/sub based on the idea that messages are tagged. To subscribe, a client simply constructs a list of tags that it is interested in, and all messages that are tagged with all of those tags are sent to that client. A client can not only be a subscriber (with multiple active subscriptions), but also a publisher. Clients will receive messages for any tags they are subscribed, except message publish by themselves.
pub-sub nanobox tcp-client websocket-client messaging developer-tools devtools nanopackThe Web Solutions Platform (WSP) event system is a general-purpose distributed publish/subscribe event system designed for high performance and low latency. Publish/subscribe is a common communication pattern though there are many variations to solve different scenario require...
distributed-systems architecture biztalk distributed esbJafka mq is a distributed publish-subscribe messaging system cloned from Apache Kafka.
publish-subscribe message-queue pub-sub distributed kafka-alternative kafka-cloneA high-throughput, persistent, distributed, publish-subscribe messaging system based on memory mapped file and Thrift RPC.
publish-subscribe message-queue pub-sub distributed thrift-rpcMBassador is a light-weight, high-performance event bus implementing the publish subscribe pattern. It is designed for ease of use and aims to be feature rich and extensible while preserving resource efficiency and performance. The core of MBassador is built around a custom data structure that provides non-blocking reads and minimized lock contention for writes such that performance degradation of concurrent read/write access is minimal.
event-bus messaging message-queue pub-sub publish-subscribePrivate Pub is a Ruby gem for use with Rails to publish and subscribe to messages through Faye. It allows you to easily provide real-time updates through an open socket without tying up a Rails process. All channels are private so users can only listen to events you subscribe them to. Watch RailsCasts Episode 316 for a demonstration of Private Pub.
Golang long polling library. Makes web pub-sub easy via an HTTP long-poll server.To use, create a LongpollManager and then use it to publish events and expose an HTTP handler to subscribe to events.
messaging pub-sub message-queueKapacitor is a open source framework for processing, monitoring, and alerting on time series data. Kapacitor imports (stream or batch) time series data, and then transform, analyze, and act on the data. It uses Telegraf to collect system metrics on your local machine and store them in InfluxDB.
monitoring data-processing data-analysis alerts streaming data-streaming streaming-analyticsReactive Extensions for Python (RxPY) is a set of libraries for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in Python. Using Rx, developers represent asynchronous data streams with Observables, query asynchronous data streams using operators, and parameterize concurrency in data/event streams using Schedulers.Using Rx, you can represent multiple asynchronous data streams (that come from diverse sources, e.g., stock quote, Tweets, computer events, web service requests, etc.), and subscribe to the event stream using the Observer object. The Observable notifies the subscribed Observer instance whenever an event occurs.You can put various transformations in-between the source Observable and the consuming Observer as well.
reactive reactivex reactive-extensions rxpyRedisson - distributed Java objects and services (Set, Multimap, SortedSet, Map, List, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, AtomicLong, Map Reduce, Publish / Subscribe, Bloom filter, Spring Cache, Executor service, Tomcat Session Manager, Scheduler service, JCache API) on top of Redis server. Rich Redis client.
cache distributed-caching distributed-locks redis-client redis-cluster collections java-collections hashmap set queueActiveMQ Apollo is a faster, more reliable, easier to maintain messaging broker built from the foundations of the original ActiveMQ. It accomplishes this using a radically different threading and message dispatching architecture. Like ActiveMQ, Apollo is a multi-protocol broker and supports STOMP, AMQP, MQTT, Openwire, SSL, and WebSockets.
messaging message-queue queue publish-subscribe pub-sub mqtt stomp amqpMessaging patterns for Backbone applications.
backbone marionette radio pub-sub decoupling messaging request events backbone-applications decoupled pubsub publish subscribe architecture spaCustom event/messaging system for JavaScript inspired by AS3-Signals.For a more in-depth introduction read the JS-Signals Project Page and visit the links below.
js-signals signals pub/sub event publish subscribe observerIt's a drop in replacement for existing EventEmitters, but just faster. Free performance, who wouldn't want that? The EventEmitter is written in EcmaScript 3 so it will work in the oldest browsers and node versions that you need to support.We've upgraded the API of the EventEmitter.on, EventEmitter.once and EventEmitter.removeListener to accept an extra argument which is the context or this value that should be set for the emitted events. This means you no longer have the overhead of an event that required fn.bind in order to get a custom this value.
eventemitter nodejs browser eventemitter2 eventemitter3 events addeventlistener addlistener emit emits emitter event once pub/sub publish reactor subscribeSubscribers implement event handling methods that will be called when an event is received. Post an event from any part of your code. All subscribers matching the event type will receive it.
pub-sub eventbus communication notifications thread iosSimple and tiny event emitter library for JavaScript. Methods on returns unbind function. Call it and this listener will be removed from event.
eventemitter events emit emitter event pub/sub publish reactor subscribeNATS Server is a simple, high performance open source messaging system for cloud native applications, IoT messaging, and microservices architectures. It implements a highly scalable and elegant publish-subscribe (pub/sub) distribution model. The performant nature of NATS make it an ideal base for building modern, reliable, scalable cloud native distributed systems.
messaging message-bus message-queue cloud-native microservices-architecture nats-server distributed-systems cloud cloud-computingWatermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling event sourcing, RPC over messages, sagas and basically whatever else comes to your mind. You can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog if that fits your use case. Note: Watermill should run reliably in a production environment, but it is still under heavy development and the public API may change before the 1.0.0 release.
watermill event-driven event-sourcing sagas events stream-processing reactive rabbitmq kafka cqrs
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.