-
Notifications
You must be signed in to change notification settings - Fork 596
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
Extend Firebase SDK with new APIs to consume streaming callable function response #6602
Extend Firebase SDK with new APIs to consume streaming callable function response #6602
Conversation
…ion response. - Handling the server-sent event (SSE) parsing internally - Providing proper error handling and connection management - Maintaining memory efficiency for long-running streams
…ion response. - Handling the server-sent event (SSE) parsing internally - Providing proper error handling and connection management - Maintaining memory efficiency for long-running streams
a6fbadc
to
f0bd47a
Compare
…m-functions-api # Conflicts: # firebase-functions/src/androidTest/java/com/google/firebase/functions/StramTests.kt
f0bd47a
to
6d3012d
Compare
…ivestreams.Subscriber interface.
…ndroid-sdk-fork into stream-functions-api
is this PR ready for review? please assign @emilypgoogle and myself as reviewers as soon as it's ready. Thanks |
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.
The PR is ready for review.
firebase-functions/src/main/java/com/google/firebase/functions/FirebaseFunctions.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/FirebaseFunctions.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/FirebaseFunctions.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/FirebaseFunctions.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/StreamResponse.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/androidTest/java/com/google/firebase/functions/StreamTests.kt
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/HttpsCallableReference.kt
Outdated
Show resolved
Hide resolved
Please, regenerate the api.txt file |
firebase-functions/src/main/java/com/google/firebase/functions/FirebaseFunctions.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/HttpsCallableReference.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/PublisherStream.kt
Show resolved
Hide resolved
firebase-functions/src/androidTest/java/com/google/firebase/functions/StreamTests.kt
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/PublisherStream.kt
Outdated
Show resolved
Hide resolved
firebase-functions/src/main/java/com/google/firebase/functions/PublisherStream.kt
Outdated
Show resolved
Hide resolved
Done |
…Synchronize request(n), and Handle Late Subscribers.
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.
Aside from my excessive synchronization comments which are non-blocking, all of my concerns were addressed and this seems to add the feature in line with reactive stream behavior expectations. @rlazo should make sure his concerns are also addressed
firebase-functions/src/main/java/com/google/firebase/functions/HttpsCallableReference.kt
Outdated
Show resolved
Hide resolved
…LargeData on index.js. - Modify genStreamError.
firebase-functions/src/main/java/com/google/firebase/functions/HttpsCallableReference.kt
Show resolved
Hide resolved
…ion response (firebase#6602) Extend Firebase SDK with new APIs to consume streaming callable function response. - Handling the server-sent event (SSE) parsing internally - Providing proper error handling and connection management - Maintaining memory efficiency for long-running streams --------- Co-authored-by: Rodrigo Lazo <[email protected]>
Extend Firebase SDK with new APIs to consume streaming callable function response.