Merge pull request #212 from TORISOUP/fix_Trampoline

Fixed Trampoline could not be reused

src/R3/Operators/Trampoline.cs

@@ -67,6 +67,7 @@ void DrainMessages()
 
                 if (!queue.TryDequeue(out value))
                 {
+                    running = false;
                     return;
                 }
             }

tests/R3.Tests/OperatorTests/TrampolineTest.cs

@@ -77,4 +77,42 @@ public void Trampoline()
 C : OnPlayerAddTeam
 """);
     }
+
+
+    [Fact]
+    public void TrampolineIsReusable()
+    {
+        var sender = new Subject<string>();
+        var receiver = sender.Trampoline().Share();
+
+        var log = new List<string>();
+
+        // A
+        receiver.Subscribe(x =>
+        {
+            log.Add(x);
+            if (x == "OnPlayerJoined") sender.OnNext("OnPlayerAddTeam");
+        });
+
+        sender.OnNext("OnPlayerJoined");
+
+        var msg = string.Join(Environment.NewLine, log);
+
+        msg.Should().Be("""
+                        OnPlayerJoined
+                        OnPlayerAddTeam
+                        """);
+
+        // reset logs
+        log.Clear();
+
+        // send again
+        sender.OnNext("OnPlayerJoined");
+
+        msg = string.Join(Environment.NewLine, log);
+        msg.Should().Be("""
+                        OnPlayerJoined
+                        OnPlayerAddTeam
+                        """);
+    }
 }