diff --git a/Refit.GeneratorTests/ReturnTypeTests.cs b/Refit.GeneratorTests/ReturnTypeTests.cs
index b7469e5cb..01849f412 100644
--- a/Refit.GeneratorTests/ReturnTypeTests.cs
+++ b/Refit.GeneratorTests/ReturnTypeTests.cs
@@ -71,4 +71,14 @@ public Task GenericStructConstraintReturnTask()
             Task<string> Get<T>() where T : struct
             """);
     }
+
+    [Fact]
+    public Task ReturnIObservable()
+    {
+        return Fixture.VerifyForBody(
+            """
+            [Get("/users/{user}")]
+            IObservable<HttpResponseMessage> GetUser(string user);
+            """);
+    }
 }
diff --git a/Refit.GeneratorTests/_snapshots/ReturnTypeTests.ReturnIObservable#IGeneratedClient.g.verified.cs b/Refit.GeneratorTests/_snapshots/ReturnTypeTests.ReturnIObservable#IGeneratedClient.g.verified.cs
new file mode 100644
index 000000000..b012fe00c
--- /dev/null
+++ b/Refit.GeneratorTests/_snapshots/ReturnTypeTests.ReturnIObservable#IGeneratedClient.g.verified.cs
@@ -0,0 +1,57 @@
+//HintName: IGeneratedClient.g.cs
+#nullable disable
+#pragma warning disable
+namespace Refit.Implementation
+{
+
+    partial class Generated
+    {
+
+    /// <inheritdoc />
+    [global::System.Diagnostics.CodeAnalysis.ExcludeFromCodeCoverage]
+    [global::System.Diagnostics.DebuggerNonUserCode]
+    [global::RefitInternalGenerated.PreserveAttribute]
+    [global::System.Reflection.Obfuscation(Exclude=true)]
+    [global::System.ComponentModel.EditorBrowsable(global::System.ComponentModel.EditorBrowsableState.Never)]
+    partial class RefitGeneratorTestIGeneratedClient
+        : global::RefitGeneratorTest.IGeneratedClient
+
+    {
+        /// <inheritdoc />
+        public global::System.Net.Http.HttpClient Client { get; }
+        readonly global::Refit.IRequestBuilder requestBuilder;
+
+        /// <inheritdoc />
+        public RefitGeneratorTestIGeneratedClient(global::System.Net.Http.HttpClient client, global::Refit.IRequestBuilder requestBuilder)
+        {
+            Client = client;
+            this.requestBuilder = requestBuilder;
+        }
+
+
+        private static readonly global::System.Type[] ______typeParameters = new global::System.Type[] {typeof(string) };
+
+        /// <inheritdoc />
+        public global::System.IObservable<global::System.Net.Http.HttpResponseMessage> GetUser(string @user)
+        {
+            var ______arguments = new object[] { @user };
+            var ______func = requestBuilder.BuildRestResultFuncForMethod("GetUser", ______typeParameters );
+
+            return (global::System.IObservable<global::System.Net.Http.HttpResponseMessage>)______func(this.Client, ______arguments);
+        }
+
+        private static readonly global::System.Type[] ______typeParameters0 = new global::System.Type[] {typeof(string) };
+
+        /// <inheritdoc />
+        global::System.IObservable<global::System.Net.Http.HttpResponseMessage> global::RefitGeneratorTest.IGeneratedClient.GetUser(string @user)
+        {
+            var ______arguments = new object[] { @user };
+            var ______func = requestBuilder.BuildRestResultFuncForMethod("GetUser", ______typeParameters0 );
+
+            return (global::System.IObservable<global::System.Net.Http.HttpResponseMessage>)______func(this.Client, ______arguments);
+        }
+    }
+    }
+}
+
+#pragma warning restore