Convert async iterables, iterators, or array-like objects into arrays.
Creates a parallel transform from async function
create pull-stream from async callback
An implementation for Array.fromAsync, which dumps an async iterator into an array.
Fetch API Response objects made from async generators. Build streaming HTML responses or SSE with JS sugar.
Create Most.js Streams from async iterables
Catch errors from async express routes and pass them to error catcher middleware
ESDoc plugin that copies documentation from async methods to their sync versions
Extended from `async-injection` originally authored by Frank Stock
A cross-platform React image uploader component supporting click-to-pick, drag-and-drop (web), controlled and uncontrolled usage, image preview with hover-to-remove, automatic loading state from async `onUpload`, error states, and a wide horizontal layout
Read from async iterators
Help migrate bluebird from async/await
Easy to got error from async promise flow
```jsx harmony import asyncComponent from 'async-component';
just the .queue method from async
lightweight server to aggregate response from async requests
Load all objects from async map.
Convert asyncGenerator object to Rx.Observable
Higher-order functions and common patterns for asynchronous code
Create thunk from async or sync function. Works like `thunkify`.
Encapsulate using states from async request in React.
Determine if a function is a native async function.
A tiny (183B to 210B) and fast utility to ascend parent directories
`net.Server#listen()` helper that returns a Promise for async / await
A simple API for asynchronous flow control to make it clear when jobs finish.
This is an async implementation of Mediator pattern with pipline behaviors. It is a port of Mediatr from .Net C#
Removing boilerplate from async code
Offload async HTTP requests from Solid Queue workers to a dedicated async I/O processor
MrDarcy takes async promises from the javascript world, DCI from Jim Gay's brain and sprinkles some ruby on top for great justice!
This is a gem that serves remote resources from a cache. If the cache gets stale, then the stale cache is served and the cache gets updated in async.
This gem provides a mechanism to offload long-running HTTP requests from Sidekiq workers to a dedicated async I/O processor running in the same process, freeing the worker thread immediately while the HTTP request is in flight.
Webhukhs is a Rails engine for processing webhooks from various services. Engine saves webhook in database first and later processes in async job.
Stream State Protocol events from Active Record models with the same DX as Turbo Broadcasts — declarative streaming, automatic callbacks, and async jobs — but with offset-based resumability and persistent event logs over HTTP.
perform-later provides asyncronous worker/job support for objects with a convention that encourages better object oriented design. It is a simple and lightweight adapter that helps decouple job/worker initialization from object behavior/logic/algorithm. It helps encourage objects with async/job/worker behavior that are more maintainable, easier to change, and faster to test thoroughly.
Kreuzberg is a high-performance document intelligence library with a Rust core and native Ruby bindings via Magnus. Extract text, metadata, and structured data from 75+ file formats including PDF, DOCX, PPTX, XLSX, HTML, RTF, images (with OCR), email, archives, and more. Features async/sync APIs, text chunking, language detection, and keyword extraction.
Rails engine that tracks ActiveRecord create, update, and destroy events as structured JSON records. Ships a mountable web dashboard, whodunnit actor context, batch inserts via insert_all!, async writes via ActiveJob, time-travel reconstruction, RSpec matchers, Minitest assertions, and a migration path from PaperTrail.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.