New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support Streaming for Armeria backend #860
Conversation
Motivation: Armeria natively supports Streaming through Reactive Streams Modifications: - Introduce `AbstractArmeriaBackend` for common conversions - Support streaming using `Publisher` of Reactive Streams - Add new modules for better interops with other libraries - FS2 - Monix - Cats - Scalaz - ZIO Result: Better interop Armeria with sttp.
b4fc729
to
1b42d29
Compare
class ArmeriaZioHttpTest extends HttpTest[Task] with ZioTestBase { | ||
|
||
// FIXME(ikhoon): A request failed with `ResponseTimeoutException`. | ||
// However, "read exceptions - timeout" test never ends. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't know why read exceptions - timeout
test never ends.
Can I get some advice?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
does this happen only for the zio backend? and both locally and on CI?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
- It only happens for the ZIO backend.
- It is reproducible locally.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There was a bug in closing a client factory. The problem is fixed now.
/cc @ngbinh |
Awesome. 🤩 |
All known failed tests are fixed. Not sure that the failed tests in CI are related to this PR. |
@adamw Thanks for the quick merge. I left a comment on your revise. |
awesome! Will try armeria backend when the new sttp release. |
Motivation:
Armeria natively supports Streaming through Reactive Streams
Modifications:
AbstractArmeriaBackend
for common conversionsPublisher
of Reactive StreamsResult:
Better interop Armeria with sttp.
Before submitting pull request:
sbt compile
sbt compileDocs
sbt test
sbt scalafmt