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);
    }
}