fills objects with related data. DB agnostic. One DB query per source, all queries running parallel. No loops inside, stream based.
subscribe-for-data adapter for usage with mongoose models
Task and Message Queues with Multiple Providers
A single, throttle built-in solution to subscribe to browser UI Events.
A native C++ Node module for querying and subscribing to filesystem events. Used by Parcel 2.
Manage React effect listeners with ease.
An Implementation of ES Observables
Provides a context-saving pub/sub channel to connect diagnostic event publishers and subscribers
Simple pub/sub messaging for the web
Welcome to the README of Gurx, an typescript-native reactive state management library for complex web applications and components that do not have the symmetry of the store object and the component tree.
Subscribe to non top-level stores in your Svelte templates
Paste spreadsheet cells as a Markdown table.
A websocket transport for GraphQL subscriptions
Postgres everywhere - your data, in sync, wherever you need it.
A native C++ Node module for querying and subscribing to filesystem events. Used by Parcel 2.
Helpers for creating subscription-based event emitters
Easiest way to subscribe and unsubscribe browser / node events
🚅 Modern event listener for efficient web applications based on subscribe-publish pattern.
Browser polyfill for Node.js diagnostics_channel
Rpc and pub/sub between Python and JavaScript over WebSockets
TypeScript Utilities for EIP-6963
State management for React Native
A collection of reactive wrappers for various browser APIs.
RxJS-based message/event bus service for Angular.
Use timestamp values to represent boolean data such as deleted, published, or subscribed.
A migrator that handles changing RabbitMQ queue arguments for Sneakers subscribers, ensuring smooth transitions without data loss.
You can use em-emitter to communicate with other objects in the Eventmachine reactor by subscribing to events and emitting them with encapsulated pieces of data.
Buffered Queue which flush the data when the queue max size has reached and all other subscribers which are listening to
Upkeep records the data and identity dependencies used while Rails renders a view, then updates subscribed frames when matching application data changes.
Geoptima is a suite of applications for measuring and locating mobile/cellular subscriber experience on GPS enabled smartphones. It is produced by AmanziTel AB in Helsingborg, Sweden, and supports many phone manufacturers, with free downloads from the various app stores, markets or marketplaces. This Ruby library is capable of reading the JSON format files produced by these phones and reformating them as CSV, GPX and PNG for further analysis in Excel. This is a simple and independent way of analysing the data, when compared to the full-featured analysis applications and servers available from AmanziTel. If you want to analyse a limited amount of data in excel, or with Ruby, then this GEM might be for you. If you want to analyse large amounts of data, from many subscribers, or over long periods of time then rather consider the NetView and Customer IQ applications from AmanziTel at www.amanzitel.com. Current features available in the library and the show_geoptima command: * Import one or many JSON files * Organize data by device id (IMEI) into datasets * Split by event type * Time ordering and time correlation (associate data from one event to another): ** Add GPS locations to other events (time window and interpolation algorithms) ** Add signal strenth, battery level, etc. to other events * Export event tables to CSV format for further processing in excel * Make and export GPS traces in GPX and PNG format for simple map reports The amount of data possible to process is limited by memory, since all data is imported in ruby data structures for procssing. If you need to process larger amounts of data, you will need a database-driven approach, like that provided by AmanziTel's NetView and Customer IQ solutions. This Ruby gem is actually used by parts of the data pre-processing chain of 'Customer IQ', but it not used by the main database and statistics engine that generates the reports.
This gem has been extracted from chat application based on websockets. It consists of basically two components: channels and notifiers. Channels are meant to handle external communication through provided socket in a bidirectional manner while using notifiers for internal communication. Notifiers are using a messaging bus, which might be anything supporting publish/subscribe pattern across multiple threads / processes, i.e. common Redis cluster. It lets you define your own handlers for receiving and sending data.