Piotr Gawryś

Implementation should be quite simple but it probably requires a new `Coeval` node to request something from the run loop. I didn't implement it initially because I'm not sure if...

Optimize Observable#bufferSliding

2

It seems to be a big bottleneck in one of the [benchmarks](https://github.com/monix/monix/blob/series/3.x/benchmarks/shared/src/main/scala/monix/benchmarks/ChunkedEvalFilterMapSumBenchmark.scala) Sample results: ``` [info] Benchmark (chunkCount) (chunkSize) Mode Cnt Score Error Units [info] akka 1000 1000 thrpt 20...

As a follow-up to https://github.com/monix/monix/pull/1267 we could consider tracing more operators in Cached Tracing Mode, just like we trace `MapBoth` and few others. Operators to consider: - race - parSequence...

We should seriously consider auto-isolating `Local` in `Task` in any concurrent operators that spawn "child" fibers, similarly to https://github.com/monix/monix/pull/1044 ```scala val local = Local(0) val childTaskA = Task(local := 200)...

Currently `OverflowStrategy` forbids buffers of size 1 but we could support it with a specialized implementation

I believe both RX and Akka have options for it and it could be very nice to have it in Monix as well High level implementation could look like this...

Observable.debounce is not consistent with ReactiveX

5

In our doc: ```scala Note: If the source observable keeps emitting items more frequently than the length of the time window, then no items will be emitted by the resulting...

Revise Observable.mapParallelOrdered

6

[Implementation](https://github.com/monix/monix/blob/master/monix-reactive/shared/src/main/scala/monix/reactive/internal/operators/MapParallelOrderedObservable.scala) is quite complicated and perhaps could be improved. I would like to see benchmark vs `Observable.mapParallelUnordered` and then if replacing `java.ConcurrentQueue` with the one from `jctools` (`LowLevelQueue`) has any...

Observable.toInputStream

6

We have [Observable.fromInputStream](https://github.com/monix/monix/blob/master/monix-reactive/shared/src/main/scala/monix/reactive/Observable.scala#L4503) but we're missing `toInputStream`. [FS2](https://github.com/functional-streams-for-scala/fs2/blob/series/1.0/io/src/main/scala/fs2/io/JavaInputOutputStream.scala) and [Akka Streams](https://github.com/akka/akka/blob/master/akka-stream/src/main/scala/akka/stream/impl/io/InputStreamSinkStage.scala) implementations for reference

Add dayofyear, weekofyear, month, dayofmonth, minute, second, next_da…

4

…y Column functions Related to #164