RxJS MCP Server

# Install globally
npm install -g @shuji-bonji/rxjs-mcp

# Or use with npx
npx @shuji-bonji/rxjs-mcp

{
 "mcpServers": {
 "rxjs": {
 "command": "npx",
 "args": ["@shuji-bonji/rxjs-mcp"]
 }
 }
}

{
 "mcpServers": {
 "rxjs": {
 "command": "npx",
 "args": ["@shuji-bonji/rxjs-mcp"]
 }
 }
}

{
 "mcpServers": {
 "rxjs": {
 "command": "npx",
 "args": ["@shuji-bonji/rxjs-mcp"]
 }
 }
}

// ✅ Trailing expression (v0.2.0+): the last expression is returned implicitly
interval(100).pipe(
 take(5),
 map((x) => x * 2),
);

// ✅ Declaration + trailing reference
const stream$ = interval(100).pipe(
 take(5),
 map((x) => x * 2),
);
stream$;

// ✅ Explicit return (always works)
return interval(100).pipe(
 take(5),
 map((x) => x * 2),
);

// Input: array of timed events
[
 { time: 0, value: 'A' },
 { time: 50, value: 'B' },
 { time: 100, value: 'C' },
];

// Output: A----B----C--|

// Analyzes chains like:
source$.pipe(
 map((x) => x * 2),
 filter((x) => x > 10),
 switchMap((x) => fetchData(x)),
 retry(3),
);

// Detects issues like:
- Missing unsubscribe
- No takeUntil operator
- Uncompleted Subjects
- Infinite intervals

User: "Execute this RxJS stream and show me the output"

Claude: I'll execute that RxJS stream for you.

[Uses execute_stream tool]

## Stream Execution Result
✅ Completed
Execution Time: 523ms
Values Emitted: 5

### Emitted Values
[0, 2, 4, 6, 8]

User: "Check this Angular component for memory leaks"

Claude: I'll analyze your component for potential memory leaks.

[Uses detect_memory_leak tool]

## Memory Leak Analysis
⚠️ Potential leaks detected

1. 🔴 subscription (high severity)
 - Found 3 subscribe() calls but only 1 unsubscribe()
 - Fix: Use takeUntil pattern with destroy$ subject

User: "Show me how to implement search with RxJS"

Claude: I'll show you the search typeahead pattern.

[Uses suggest_pattern tool with useCase: 'search-typeahead']

## Search Typeahead with Debounce
[Full implementation with explanation]

# Clone the repository
git clone https://github.com/shuji-bonji/rxjs-mcp-server
cd rxjs-mcp-server

# Install dependencies
npm install

# Build
npm run build

# Run tests
npm test # Unit tests (vitest)
npm run test:mcp # MCP integration test
npm run test:inspector # MCP Inspector (GUI)

# Run in development
npm run dev

┌─────────────────┐
│ AI Assistant │
│ (Claude, etc) │
└────────┬────────┘
 │
 MCP Protocol
 │
┌────────┴────────┐
│ RxJS MCP Server│
├─────────────────┤
│ • execute_stream│
│ • generate_marble│
│ • analyze_operators│
│ • detect_memory_leak│
│ • suggest_pattern│
└─────────────────┘