-
Notifications
You must be signed in to change notification settings - Fork 127
feat(data): Events API Connection ack timeout handling #3020
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
Conversation
|
Addressed @mattcreaser 's previous PR comments from: #3018 |
| val connectionInitMessage = json.encodeToString(WebSocketMessage.Send.ConnectionInit()) | ||
| logger?.debug { "$TAG onOpen: sending connection init" } | ||
| webSocket.send(connectionInitMessage) | ||
| logger?.debug { "onOpen: sending connection init" } |
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.
Static logs like this can use direct function invocation instead of lambda form
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.
fixed for all the simple, non throwable providing log types.
| // so inspecting code/reason isn't helpful as it should be | ||
| logger?.debug("$TAG onClosed: userInitiated = $userInitiatedDisconnect") | ||
| notifyClosed() | ||
| logger?.debug("onClosed: reason = $disconnectReason") |
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.
Logs with concatenation should probably be using lambda form
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.
fixed.
Issue #, if available:
Description of changes:
How did you test these changes?
(Please add a line here how the changes were tested)
Documentation update required?
General Checklist
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.