-
Notifications
You must be signed in to change notification settings - Fork 36
Streaming support in Udash REST #1338
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
base: master
Are you sure you want to change the base?
Conversation
Since @mrzysztof is taking over this, I think @sebaciv could review. I'll take a look but won't have the time to be the primary reviewer here. |
rest/jetty/src/main/scala/io/udash/rest/jetty/JettyRestClient.scala
Outdated
Show resolved
Hide resolved
@@ -129,6 +146,52 @@ trait RestApiTestScenarios extends RestApiTest { | |||
} | |||
} | |||
|
|||
class DirectRestApiTest extends RestApiTestScenarios { | |||
def clientHandle: HandleRequest = serverHandle | |||
// TODO streaming MORE tests: cancellation, timeouts, errors, errors after sending a few elements, custom format, slow source observable |
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 can't find tests for mid-stream Observable cancellation (both server and client side), is this corner case unhandled?
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 tinkered with that, but in the end, I am not really sure what the expected outcome is here.
Suppose we cancel the subscription from the client. What do we want to test here?
Enable returning monix.Observable in REST RPC traits and stream response when sending it over the wire.
State of this pull request (missing items):