WIP: Support custom serialization for RequestContent

.vscode/cspell.json

@@ -72,6 +72,7 @@
     "rustup",
     "seekable",
     "servicebus",
+    "spector",
     "stylesheet",
     "subclient",
     "telemetered",

sdk/storage/azure_storage_blob/src/clients/block_blob_client.rs

@@ -95,7 +95,7 @@ impl BlockBlobClient {
     /// * `options` - Optional configuration for the request.
     pub async fn commit_block_list(
         &self,
-        blocks: RequestContent<BlockLookupList>,
+        blocks: RequestContent<BlockLookupList, XmlFormat>,
         options: Option<BlockBlobClientCommitBlockListOptions<'_>>,
     ) -> Result<Response<BlockBlobClientCommitBlockListResult, NoFormat>> {
         self.client.commit_block_list(blocks, options).await

sdk/storage/azure_storage_blob/tests/block_blob_client.rs

@@ -74,10 +74,8 @@ async fn test_block_list(ctx: TestContext) -> Result<(), Box<dyn Error>> {
         uncommitted: Some(Vec::new()),
     };
 
-    let request_content = RequestContent::try_from(block_lookup_list)?;
-
     block_blob_client
-        .commit_block_list(request_content, None)
+        .commit_block_list(block_lookup_list.try_into()?, None)
         .await?;
 
     // Three Committed Blocks Scenario

sdk/typespec/typespec_client_core/Cargo.toml

@@ -22,7 +22,7 @@ rand.workspace = true
 reqwest = { workspace = true, optional = true }
 rust_decimal = { workspace = true, optional = true }
 serde.workspace = true
-serde_json.workspace = true
+serde_json = { workspace = true, features = ["raw_value"] }
 time.workspace = true
 tokio = { workspace = true, optional = true }
 tracing.workspace = true

sdk/typespec/typespec_client_core/src/fs/tokio.rs

@@ -172,14 +172,14 @@ impl From<FileStream> for Body {
 }
 
 #[cfg(not(target_arch = "wasm32"))]
-impl<T> From<&FileStream> for RequestContent<T> {
+impl<T, F> From<&FileStream> for RequestContent<T, F> {
     fn from(stream: &FileStream) -> Self {
         Body::from(stream).into()
     }
 }
 
 #[cfg(not(target_arch = "wasm32"))]
-impl<T> From<FileStream> for RequestContent<T> {
+impl<T, F> From<FileStream> for RequestContent<T, F> {
     fn from(stream: FileStream) -> Self {
         Body::from(stream).into()
     }