redglow
27 lines
484 B
C#
27 lines
484 B
C#
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);
|
|
}
|
|
} |