We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6e4d8d8 commit 6d92e67Copy full SHA for 6d92e67
moqt-server/src/modules/message_handlers/control_message/handlers/subscribe_handler.rs
@@ -40,14 +40,14 @@ pub(crate) async fn subscribe_handler(
40
let downstream_subscribe_id = subscribe_message.subscribe_id();
41
let downstream_session_id = client.id();
42
43
- if pubsub_relation_manager_repository
+ if !pubsub_relation_manager_repository
44
.is_downstream_subscribe_id_unique(downstream_subscribe_id, downstream_session_id)
45
.await?
46
{
47
bail!("DuplicateSubscribeID");
48
}
49
50
51
.is_downstream_subscribe_id_less_than_max(downstream_subscribe_id, downstream_session_id)
52
53
0 commit comments