Voltaire Effect Streaming

Stream blockchain block and event data with reorg detection via Effect pipelines.

Updated Feb 6, 2026

Search Tags:#real-time #streaming #blockchain #effect-ts #websocket #typed-errors #reorg-detection

Ready to run

npx skills add https://github.com/cyotee/voltaire-skill --skill voltaire-effect-streaming

💬 Prompt for ChatGPT / Claude Chat▼

Please help me install this Agent Skill.
Skill: Voltaire Effect Streaming
Source: https://github.com/cyotee/voltaire-skill/tree/main/.opencode/skills/voltaire-effect-streaming
Command: npx skills add https://github.com/cyotee/voltaire-skill --skill voltaire-effect-streaming

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Real-time blockchain streaming with built-in reorg detection, typed streaming errors, and composable Effect workflows reduces the complexity of building live data pipelines for blocks and contract events.

Core Features & Use Cases

Real-time block streaming with unsubscribe capability
Event/log streaming with configurable fromBlock/toBlock and topics
Built-in reorg detection and typed streaming errors
WebSocket transport support for low-latency subscriptions

Quick Start

Start a live block stream with watchBlocks and handle new blocks via a callback.

Frequently Asked Questions about Voltaire Effect Streaming

High-intent search queries and answers about installing and using this skill.

FAQPage Schema

How do I stream real-time blockchain events with typed error handling in TypeScript?▼

Real-time blockchain streaming in TypeScript uses Effect-based pipelines to consume block and event data while enforcing typed streaming errors, ensuring type-safe error handling for live network data subscriptions.

What is the best way to detect blockchain reorgs during live event streaming?▼

Blockchain reorg detection is built directly into the streaming pipeline, automatically identifying chain reorganizations during live block and event consumption to prevent processing inconsistent state data.

How do I use Effect workflows for WebSocket blockchain subscriptions?▼

Effect workflows support WebSocket transport to establish low-latency blockchain subscriptions, allowing you to composable pipe block and event streams through Effect-based pipelines in TypeScript.

Can I filter contract event logs by block range and topics when streaming?▼

Event and log streaming supports configurable fromBlock and toBlock parameters alongside specific topic filtering, enabling targeted contract event consumption within the Effect-based streaming pipeline.

Does Effect-ts support composable pipelines for live block monitoring?▼

Effect-ts supports composable workflows for live block monitoring by providing real-time block streaming with unsubscribe capability, allowing you to handle new blocks via callbacks within Effect pipelines.