return none if subscription returns early#250
Conversation
Signed-off-by: Gregory Hill <gregorydhill@outlook.com>
| } | ||
| let change_set = match self.subscription.next().await { | ||
| Some(c) => c, | ||
| None => { |
There was a problem hiding this comment.
The proper action should be to indicate that the subscription is dropped and need to restarted because after it returns None it shouldn't be polled anymore because the channel has been terminated.
If you poll if after None it will panic
There was a problem hiding this comment.
Which is exactly why I would expect it to return None, to indicate the stream has closed (much like with StreamExt).
There was a problem hiding this comment.
Alright, that makes sense to me but perhaps we should document it because it's not obvious to me ^^
Signed-off-by: Gregory Hill <gregorydhill@outlook.com>
|
I think our CI is broken, all test runs are hanging now, possibly due to recent |
|
I get this locally: |
Signed-off-by: Gregory Hill <gregorydhill@outlook.com>
|
I don't think the CI issue is related to the client changes as it was working before on this pipeline, also worked locally for me with these latest changes. Is it possible it has something to do with the environment? There's an annotation on the last successful run that |
|
@gregdhill please merge master, it should fix CI |
Signed-off-by: Gregory Hill gregorydhill@outlook.com