17 lines
462 B
C#
17 lines
462 B
C#
namespace DTLib.Experimental.Reactive
|
|
{
|
|
public class ReactiveSender<T> : ReactiveProvider<T>
|
|
{
|
|
|
|
public ReactiveSender() { }
|
|
public ReactiveSender(ReactiveStream<T> stream) : base(stream) { }
|
|
public ReactiveSender(ICollection<ReactiveStream<T>> streams) : base(streams) { }
|
|
|
|
public void Send(T e)
|
|
{
|
|
foreach (ReactiveStream<T> s in Streams)
|
|
s.Add(e);
|
|
}
|
|
}
|
|
}
|