Jérémie Fache

Hello, ~~I don't know actually why but it does not work when "flat mapping" multiple embeded iterables~~. **Edit**: forget my answer, I was wrong with my example. I need more...

@ericbottard After some tests, grouped Observables created by `group_by_until` (and `group_by`) are not compatible with `to_iterable`, due to the type of subject used to create those observables: `Subject` does not...

Yes, it would require some changes in `group_by` and `group_by_until` codes and signatures to support a subject factory, something like: ```python def group_by( key_mapper: Mapper, element_mapper: Optional[Mapper] = None, subject_mapper:...

In fact I think `take` operator messes things up in your example. I will try to explain but it's not trivial. ~~The resulting observable completes at "3" because this is...

> I would expect the take(3) to act on the "outer" (ie groups) observable, and have no impact on the "inner" (ie the contents of the groups) observable. Yes, I...

Hi, Maybe I'm missing something but why not using the `publish` operator which returns a connectable Observable for this particular case? ```python shared_obs = rx.just(3, scheduler=my_scheduler).pipe(rx_op.publish()) left_obs = shared_obs.pipe(rx_op.first()) right_obs...

@MainRo I don't think there's currently an operator with a static/forced scheduler, but some creation operators don't use subscription scheduler anyway so it should be ok to have something like...

Hi, I've been running a bunch of tests with a simpler sample and a slightly different way of monitoring memory, RxPY3 (HEAD master), python 3.7.3 & linux. I must say...

Same here with a Fairphone 2 and Android 7.1.2 ( os fairphone open 19.11.2).

Hi, I'm experiencing the same issue on Windows, zarr 2.10.2. After digging a bit, It appears that the lock mechanism is done on a per chunk basis, in `Array._chunk_setitem` method....