genkitx-rxjs

genkitx-rxjs is a lightweight adapter that integrates RxJS with Firebase Genkit, allowing developers to define flows using Observables. It simplifies reactive programming patterns within Genkit's flow-based architecture.

Key Features

• Observable Flow Definition — Create Genkit flows that work with RxJS Observables using defineRxFlow.
• Flow-as-Operator — Use Genkit flows as RxJS operator functions via rxFlowRun.
• Dual Compatibility — rxFlowRun supports both RxFlows and vanilla Genkit flows (defineFlow).
• Type Safety — Leverages Zod schemas for input and output validation within flows.

Philosophy

The project embraces reactive programming principles, providing a seamless bridge between Genkit's flow orchestration and RxJS's powerful observable patterns.