Oleg Pyzhcov

ConcurrentChannel with bounded buffer can deadlock with short-lived consumers

1

Using a short-lived consumer on a ConcurrentChannel may cause producer to deadlock if the buffer is bounded. I suspect it happens because the producer is waiting for a consumer to...

WIP: add option to isolate on fork

6

Posting this quick experiment to get some feedback: - new option `contextIsolationOnFork` in `Task.Options` (in an ugly, but bincompatible way) - its handling in `task.start` that makes it isolate, but...

Bump cats-effect to 3.0.0-RC2; port catnap+tests to CE3

3

Here's catnap upgrade I've been slowly doing over the past few weeks. Putting it out if you guys want to pick it up faster than I can do it (we...

Fatal exceptions can get swallowed in async operations

5

[From gitter](https://gitter.im/monix/monix?at=5d137cc5b3f22a4b2a3d8fbc) >@YulawOne Hey guys, following code is behaving differently in monix 3.0.0-RC3 and 2.3.3: ```scala Task.gatherUnordered(Seq(Task.eval(throw new NoSuchMethodError("oops")))).runSyncUnsafe() ``` >In 2.3.3 code throws java.util.concurrent.ExecutionException: Boxed Error with NoSuchMethodError as...

fs2-core 2.3.0, Scala 2.13.1, Scala.js 0.6.23 Ran into a very weird issue: - If a signal is made with some Cartesian operator like `mapN` or `product`, and - a `.discrete`...

Unclear CTE using `set"..." ~= { ... }` with a generic case class

1

I was trying to use goggles to modify a value inside a case class with a type parameter (type parameters should remain the same). Simplified, code like this: ```scala import...

@JsonCodec produces warnings on generic case class with -Wunused:params

5

circe 0.13.0 Annotating a generic case class with `@JsonCodec`: ```scala @io.circe.generic.JsonCodec case class Foo[A](data: A) object Test extends App ``` Produces warnings: ``` parameter value encode0 in method encodeFoo is...

Macro error serializing objects with numeric names

1

This code: ```scala import boopickle.Default._ case object `1` Pickle.intoBytes(`1`) ``` gives: ``` ScalaFiddle.scala:3: error: exception during macro expansion: scala.reflect.macros.ParseException: ';' expected but double literal found. at scala.reflect.macros.contexts.Parsers.$anonfun$parse$1(Parsers.scala:18) at scala.reflect.macros.contexts.Parsers.$anonfun$parse$1$adapted(Parsers.scala:17) at...

Rapture 2.0.0-M7, Scala 2.11.8 Was doing some json-based storage for a little project and found that this innocent code: ``` object JsonBufferError extends App { import rapture.json._ import jsonBackends.jawn._ JsonBuffer.parse("""{"counter":...