Voltaire Effect Streaming

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

Updated Feb 6, 2026
One-click install
npx skills add https://github.com/cyotee/voltaire-skill --skill voltaire-effect-streaming
Or copy as Structured Prompt for Agent
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.