From 5cf2bbcc38f9501f2330ff1ef28b65c883417b00 Mon Sep 17 00:00:00 2001 From: Benjamin Novak Date: Tue, 5 Mar 2024 14:56:13 +0000 Subject: [PATCH] add channel support 15 --- src/main.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main.rs b/src/main.rs index 44cc6f6..abfaeb5 100644 --- a/src/main.rs +++ b/src/main.rs @@ -48,7 +48,7 @@ fn main() -> Result<(), Error> { ); let req = Request::from_client(); - let channel = Ok(req.get_header_str("FANOUT").unwrap_or("test")).unwrap_or("test"); + let channel = Ok::<&str, E>(req.get_header_str("FANOUT").unwrap_or("test")).unwrap_or("test"); // Request is a stream request - from client, or from fanout