GitHub user pjfanning created a discussion: reduce or remove use of Scala Futures in favour of sticking to reactive streams
Based on some discussion points raised in https://github.com/apache/pekko/discussions/2431 The idea is that we might get better backpressure support if didn't run some of the internal code in this repo using Scala Futures. One area that we could start is by looking at R2dbcExecutor and trying to change its code to also support returning `Source[T]` as well as `Future[T]` so that we could migrate our internal code to use the Source based versions. We may want to keep the Future based methods for backward compatibility (and possibly deprecate them). https://github.com/apache/pekko-persistence-r2dbc/blob/main/core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/R2dbcExecutor.scala#L43-L56 Pekko Source has a `fromPublisher` method. wdyt @mdedetrich @ptrdom @He-Pin @raboof GitHub link: https://github.com/apache/pekko-persistence-r2dbc/discussions/265 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
