Bridge RxJS and Effect-TS — turn an Observable into a typed Effect Stream with backpressure and proper interruption.