set is_stream when type is duplex

Kuska-ssb · Nov 20, 2023 · 8f429b3 · 8f429b3
1 parent 71b7be6
commit 8f429b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/rpc/stream.rs b/src/rpc/stream.rs
@@ -250,7 +250,7 @@ impl<W: io::Write + Unpin> RpcWriter<W> {
 
         let rpc_header = Header {
             req_no: self.req_no,
-            is_stream: rpc_type == RpcType::Source,
+            is_stream: rpc_type == RpcType::Source || rpc_type == RpcType::Duplex,
             is_end_or_error: false,
             body_type: BodyType::JSON,
             body_len: body_str.as_bytes().len() as u32,