Promises and handlers

Templates | Reproducible randomness | Prepared maps | Nested maps

Large data crosses without copying | What crosses | What doesn’t cross | Data frames and Arrow | Mixed-language pools | The cross-language map

Nested tasks | A default pool for package code | Waiting on several tasks | Promises and handlers | Sizing, sharing and watching a pool

A data frame round trip | Five thousand small tasks | How mizu compares | Base R | mirai, crew, and future | callr | Python workers

The articles

Deploying on Linux | Linux memory allocator | Garbage collection boundary | When a process dies

1. HTTP Client | ncurl: Basic Requests | ncurl_aio: Async Requests | Promises Integration | ncurl_session: Persistent Connections | 2. WebSocket Client | 3. Unified HTTP/WebSocket Server | Handler Types | HTTP Request Handlers | Static Content Handlers | WebSocket Handlers | HTTP Streaming Handlers | Server-Sent Events | 4. Secure Connections (TLS) | Public Internet HTTPS | Self-Signed Certificates | 5. Client Example: Shiny ExtendedTask | 6. Server Example: Quarto Site with Dynamic API | 7. Server Deployment with _server.yml

1. Introduction | mirai | mirai (advanced) | daemons | 2. Error Handling | 3. Local Daemons | With Dispatcher (default) | Without Dispatcher | everywhere() | 4. Memory Management | Queue Backpressure | Non-blocking Submission | Shared Memory with Local Daemons | 5. mirai_map | Basic Usage | Collection Options | Multiple Map | Nested Maps | 6. Remote Infrastructure | Remote Daemons Overview | Launching Remote Daemons | SSH Direct Connection | SSH Tunnelling | HPC Cluster Resource Managers | Job Arrays | HTTP Launcher | Default: Posit Workbench | Custom HTTP APIs | Troubleshooting | Generic Remote Configuration | Manual Deployment | TLS Secure Connections | Automatic Zero-configuration Default | CA Signed Certificates | 7. Compute Profiles | with_daemons() and local_daemons() | With Method | 8. Advanced Topics | Random Number Generation | Synchronous Mode

1. Migration from future_promise() | 2. Setting the random seed | 3. Accessing package functions during development | 4. Why does mirai() take time when it's meant to return immediately? | 5. Creating daemons on-demand or shutting down idle daemons | 6. Launching daemons --vanilla

1. Event-driven promises | 2. Shiny ExtendedTask: Introduction | 3. Shiny ExtendedTask: Cancellation | 4. Shiny ExtendedTask: Generative Art | 5. Shiny ExtendedTask: mirai map | 6. Shiny Async: Coin Flips | 7. Shiny Async: Progress Bar | 8. Plumber GET Endpoint | 9. Plumber POST Endpoint

1. Serialization: Arrow, polars and beyond | 2. Serialization: Torch | 3. Database Hosting using Arrow Database Connectivity | 4. Shiny / mirai / DBI / ADBC Integrated Example

1. Request Reply Protocol | 2. Publisher Subscriber Protocol | 3. Surveyor Respondent Protocol | 4. Device (Broker / Proxy)

1. Agent Skill | 2. Developer Interfaces | 3. Guidance

Ichimoku Kinko Hyo | Definition | Interpretation | Context | A Typical Workflow | Data | Input data requirements | ichimoku() | ichimoku.ichimoku() | Preserving Data | Defining custom holidays | Working with ichimoku objects | plot() | 1. Static Plots | Oscillators | Custom Sub-plots | Further Options | 2. Interactive Plots | Implementation notes | archive() | Writing | Reading | Data Integrity Verification | Supplementary Information | Data validation | ichimoku object specification | API modifications | Since version 0.x | Dependencies | References

Core Concepts | Key Takeaways | 1. Basic mirai Usage | Create and Access Results | Passing Data | 2. Local Daemons | Basic Setup | Daemon Configuration | Synchronous Mode (Testing/Debugging) | 3. Remote Daemons - SSH Direct | Setup Host to Accept Remote Connections | URL Constructors | SSH Configuration | 4. Remote Daemons - SSH Tunnelling | When to Use Tunnelling | Setup | 5. HPC Cluster Configurations | General Pattern | Scheduler-Specific Directives | 6. HTTP Launcher | 7. Manual Daemon Deployment | Generate Launch Commands | 8. Compute Profiles | Multiple Independent Profiles | Scoped Profiles | 9. Common Patterns | Temporary Daemons | Mixed Local/Remote Resources | Dynamic Scaling | 10. mirai_map - Parallel Map | Basic Usage | Collection Options | Multiple Map (over DataFrame/Matrix) | 11. Error Handling | 12. Monitoring | 13. Advanced Features | Timeouts | Cancellation | Evaluation Everywhere | Random Seeds (Reproducible) | Custom Serialization | TLS Configuration | 14. Dispatcher vs. Direct | 15. Quick Decision Tree | 16. Common Gotchas

Core Concepts | Key Takeaways | 1. Sockets and Connections | Create Sockets | Protocols | Transports | 2. Send and Receive | Synchronous | Receive Modes | 3. Async I/O | Basic Async | Non-blocking Patterns | 4. Condition Variables | Basics | Pipe Notifications | Async with CV | 5. Request/Reply (RPC) | Server | Client | 6. Pub/Sub | 7. Surveyor/Respondent | 8. TLS Secure Connections | Self-signed Certificates | CA Certificates | 9. Options and Statistics | Get/Set Options | Common Options | Custom Serialization | Statistics | 10. Contexts | 11. Cross-language Exchange | R to Python (NumPy) | 12. Error Handling | 13. Utilities

1. TLS Secure Connections | 2. Options | 3. Custom Serialization | 4. Statistics

1. Cross-language Exchange | 2. Async and Concurrency | 3. Synchronisation Primitives

1. Mirai Parallel Clusters | 2. Foreach Support

1. Introduction | 2. Automatic Tracing Setup | 3. Span Types and Hierarchy | 3.1 Core Span Types | 3.2 Span Relationships and Context Propagation | 4. Status and Error Tracking | 5. Monitoring and Observability | 6. Integration with Observability Platforms

Introduction | Core Auxiliary Functions | tradingDays() | look() | Dataframe Constructors | xts_df() | matrix_df() | Dataframe Utilities | df_merge() | df_append() | Timestamp Utilities | format_POSIXct()

Introduction | Working with Strategies | 1. Use ichimoku() | 2a. Simple strategies using strat() | 2b. Complex strategies using strat() | 3. View strategy summary with summary() | 4. Visualize by calling plot() or iplot(). | 5. Combine strategies using stratcombine() | 6. Further backtesting and returns analysis | Advanced Strategies and ML | autostrat() | autostrat() Levels 2 and 3 | mlgrid() | relative() | Strategy Summary Specification | References

About OANDA fxTrade | Registering with OANDA | Setting your OANDA API Key | Using a Live Account | The OANDA Functions | oanda() | oanda_chart() | oanda_studio() | Downloading Data | oanda_stream() | oanda_quote() | oanda_view() | oanda_orders() / oanda_positions() | Available Instruments | Caching Implementation | References

Executing a C function later | Background tasks