feat: initial import

Helpers/Pipe.cs

@@ -0,0 +1,27 @@
+using System;
+using R3;
+
+namespace GodotHostTest.Helpers;
+
+public class Pipe<T> : IDisposable
+{
+    private readonly ReplaySubject<Observable<T>> _subject = new(1);
+
+    public Pipe()
+    {
+        Observable = _subject.Switch();
+    }
+
+    public Observable<T> Observable { get; }
+
+    public void Dispose()
+    {
+        _subject.Dispose();
+        GC.SuppressFinalize(this);
+    }
+
+    public void PipeIn(Observable<T> observable)
+    {
+        _subject.OnNext(observable);
+    }
+}