GitHub user He-Pin added a comment to the discussion: [Pekko Streams] Best practice for streaming from a resource that can take several seconds/minutes to start offering an element
At first, I would suggest you delegate the blocking call to a VirtualThread with Java 21, and how about make use of the Source.unfoldAsync ? For the networking , where you may not been notified, so I would suggest you attach a keepalive to get notified if you don't get the RST. GitHub link: https://github.com/apache/pekko/discussions/1572#discussioncomment-11487821 ---- This is an automatically sent email for notifications@pekko.apache.org. To unsubscribe, please send an email to: notifications-unsubscr...@pekko.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For additional commands, e-mail: notifications-h...@pekko.apache.org
