in sdk/core/azure_core_amqp/src/session.rs [108:145]
fn test_amqp_session_options_builder() {
let session_options = AmqpSessionOptions {
next_outgoing_id: Some(1),
incoming_window: Some(1),
outgoing_window: Some(1),
handle_max: Some(1),
offered_capabilities: Some(vec!["capability".into()]),
desired_capabilities: Some(vec!["capability".into()]),
properties: Some(
vec![("key", "value")]
.into_iter()
.map(|(k, v)| (AmqpSymbol::from(k), AmqpValue::from(v)))
.collect(),
),
buffer_size: Some(1024),
};
assert_eq!(session_options.next_outgoing_id, Some(1));
assert_eq!(session_options.incoming_window, Some(1));
assert_eq!(session_options.outgoing_window, Some(1));
assert_eq!(session_options.handle_max, Some(1));
assert_eq!(
session_options.offered_capabilities,
Some(vec!["capability".into()])
);
assert_eq!(
session_options.desired_capabilities,
Some(vec!["capability".into()])
);
assert!(session_options.properties.is_some());
let properties = session_options.properties.clone().unwrap();
assert!(properties.contains_key("key"));
assert_eq!(
*properties.get(&AmqpSymbol::from("key")).unwrap(),
AmqpValue::String("value".to_string())
);
assert_eq!(session_options.buffer_size, Some(1024));
}