Roman Janusz

HTTP headers and query parameters can be repeated in HTTP request. Also, query parameter may be a flag without a value (e.g. `?flag`). Currently, REST framework is unable to handle...

Scheduler.forkJoin stops executing tasks after reaching its maximum thread count

1

Try running this code: ```scala implicit val scheduler: Scheduler = Scheduler.forkJoin(4, 8) // make the pool reach its maximum thread count Task.parTraverseUnordered(0 until 1000) { _ => Task(scala.concurrent.blocking(Thread.sleep(10))) }.runSyncUnsafe() println("slept")...

Fixes #1588 `DynamicWorkerThreadFactory` was previously managing `maxThreads` parameter of `Scheduler.forkJoin` manually, instead of passing it to the `ForkJoinPool` itself. Now this is changed so that only the pool itself is...

Blocking code is not always properly handled

3

## Reproduction ```scala import monix.eval.Task import monix.execution.Scheduler object Bug extends App { implicit val scheduler: Scheduler = Scheduler.forkJoin(1, 128) val task = Task.async[Unit](_.onSuccess(())).map { _ => Task.evalAsync(println("foo")).runSyncUnsafe() } task.executeAsync.runSyncUnsafe() }...

Macro-based compile time reflection should be always confined to the same file where inspected classes are defined. This avoids problems with incremental compilation and possible duplication of macro generated code.

Heavy usage of ThreadLocals when using default ExecutionModel

1

While profiling our application, we have noticed that Monix creates a ton of `ThreadLocal` instances. After some analysis, we found that a `ThreadLocal` is created every time a `Task` is...