Dmitry

Request for More Examples for Transitioning from RxJS to Effect in docs

3

Hi guys! I am a power-user of RxJS, i know it very well including all it's weaknesses. I've been watching `Effect` for a long time, and, i assume, it could...

TypeError: Cannot use 'in' operator to search for '_op' in undefined

7

### What version of Effect is running? 3.1.2 ### What steps can reproduce the bug? ```ts import {Effect, TestClock, Console, Schedule} from "effect" const test = Effect.gen(function* () { const...

RangeError: Invalid array length when calling broadcastDynamic(Infinity)

1

### What version of Effect is running? 3.1.2 ### What steps can reproduce the bug? ```ts import { Effect, Stream } from 'effect'; const intervalStream = Stream.async(() => {}).pipe(Stream.broadcastDynamic(Infinity)); const...

### What is the problem this feature would solve? We have an extremely useful `Stream.concatAll` and `Stream.mergeAll` functions, but we don't have the same concept for zipping latest values. ###...

### What is the problem this feature would solve? Currently, TestClock requires manual time adjustments, making it cumbersome for testing complex asynchronous scenarios involving multiple parallel processes with varying delays....

Unexpected NodeJS process hanging

2

### What version of Effect is running? 3.1.5 ### What steps can reproduce the bug? ```ts const intervalStream = Stream.fromSchedule(Schedule.spaced('500 millis')) .pipe(Stream.tap(Console.log)); const program = Effect.gen(function* () { const pubsub...

feat(PubSub): unbounded replay

10

## Type - [ ] Refactor - [x] Feature - [ ] Bug Fix - [ ] Optimization - [ ] Documentation Update ## Description Implementation of replay last N...

refactor(Stream): use more common Types.TupleOf instead of Stream.DynamicTuple

3

## Type - [x] Refactor - [ ] Feature - [ ] Bug Fix - [ ] Optimization - [ ] Documentation Update ## Description ## Related - Related Issue...

feat(Stream): switchMap

10

## Type - [ ] Refactor - [x] Feature - [ ] Bug Fix - [ ] Optimization - [ ] Documentation Update ## Description ## Related - Related Issue...

feat(Stream): share

4

## Type - [ ] Refactor - [x] Feature - [ ] Bug Fix - [ ] Optimization - [ ] Documentation Update ## Description `Stream.share({ connector: PubSub.unbounded() })` returns...