modelcontextprotocol/rust-sdk
Watch
1
0
Fork
You've already forked rust-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

fix(test): fix test introduced by #97 (#101)

Browse source
This commit is contained in:
4t145 2025-04-07 17:31:56 +08:00 • committed by GitHub
commit b9be9797d1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 20 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

20
crates/rmcp/tests/test_message_protocol.rs
View file

@ -60,6 +60,7 @@ async fn test_context_inclusion_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -69,6 +70,7 @@ async fn test_context_inclusion_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(1),
meta: Default::default(),
},
)
.await?;
@ -99,6 +101,7 @@ async fn test_context_inclusion_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -108,6 +111,7 @@ async fn test_context_inclusion_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(2),
meta: Default::default(),
},
)
.await?;
@ -138,6 +142,7 @@ async fn test_context_inclusion_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -147,6 +152,7 @@ async fn test_context_inclusion_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(3),
meta: Default::default(),
},
)
.await?;
@ -197,6 +203,7 @@ async fn test_context_inclusion_ignored_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -206,6 +213,7 @@ async fn test_context_inclusion_ignored_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(1),
meta: Meta::default(),
},
)
.await?;
@ -261,6 +269,7 @@ async fn test_message_sequence_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -270,6 +279,7 @@ async fn test_message_sequence_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(1),
meta: Meta::default(),
},
)
.await?;
@ -333,6 +343,7 @@ async fn test_message_sequence_validation_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -342,6 +353,7 @@ async fn test_message_sequence_validation_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(1),
meta: Meta::default(),
},
)
.await?;
@ -364,6 +376,7 @@ async fn test_message_sequence_validation_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -373,6 +386,7 @@ async fn test_message_sequence_validation_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(2),
meta: Meta::default(),
},
)
.await;
@ -414,6 +428,7 @@ async fn test_selective_context_handling_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -423,6 +438,7 @@ async fn test_selective_context_handling_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(1),
meta: Meta::default(),
},
)
.await?;
@ -451,6 +467,7 @@ async fn test_selective_context_handling_integration() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -460,6 +477,7 @@ async fn test_selective_context_handling_integration() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(2),
meta: Meta::default(),
},
)
.await?;
@ -505,6 +523,7 @@ async fn test_context_inclusion() -> anyhow::Result<()> {
stop_sequences: None,
metadata: None,
},
extensions: Default::default(),
});
let result = handler
@ -514,6 +533,7 @@ async fn test_context_inclusion() -> anyhow::Result<()> {
peer: client.peer().clone(),
ct: CancellationToken::new(),
id: NumberOrString::Number(1),
meta: Meta::default(),
},
)
.await?;