GitHub user ptrdom edited a comment on the discussion: Artifical back pressure on JDBC projections
> Yes, if you use the pekko-streams API this is exactly what fan-in/fan-out > API's do. Fan-in/fan-out is still about connected streams, here I do not think the streams are connected. What you linked in R2DBC is offset store, not journal queries, but journal queries also operate on `Future` too. They still convert to a `SourceProvider` down the line and then the backpressure starts to work. The end-to-end streaming is likely not an option at a query level, because queries do flip flop between live data and backtracking between batches, so while I guess you could do live query as a stream, backtracking would still need to be done in batches at certain intervals. GitHub link: https://github.com/apache/pekko/discussions/2431#discussioncomment-14894351 ---- 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]
