-
Notifications
You must be signed in to change notification settings - Fork 82
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
Subscription prime #93
base: main
Are you sure you want to change the base?
Subscription prime #93
Conversation
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.
cursory comments
end | ||
|
||
defp send_msg(msg, socket) do | ||
encoded_msg = socket.serializer.fastlane!(msg) |
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.
do we care to try/catch this and return a normalized error?
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, but maybe there's a good reason to do it here?
f22e7f6
to
8c74f51
Compare
8c74f51
to
d506f01
Compare
17d069f
to
fb6d5b7
Compare
fb6d5b7
to
17d069f
Compare
This is the companion PR for absinthe-graphql/absinthe#1168
Like that one, this is still a WIP requiring documentation (and correction of dependencies once the other one is merged).
The main changes here are: a) handling of continuations (the
{:more, ...}
return values) and subscription ordinal-based filtering to avoid sending out-of-date updates.