C# Multiple Subscribers on Reactive Linq Subject

Question

Hi All,

I have a requirement to process messages fast only once. Is it possible to have multiple subscribers doing the task

Currently, i am using Reactive Linq NuGet package. Please see code snippet below

TIA

 static Subject<int> subject = new Subject<int>();
 subject
                .Buffer(TimeSpan.FromMilliseconds(1), 10)
                .Subscribe((e) => {
Console.WriteLine ($"Value = {e}");
}

Answer 1

you an use the following code block and modify

static Subject<int> subject = new Subject<int>();

// First subscriber
subject.Subscribe((e) => {
    Console.WriteLine($"Subscriber 1 received value: {e}");
});

// Second subscriber
subject.Subscribe((e) => {
    Console.WriteLine($"Subscriber 2 received value: {e}");
});

// Publish a value
subject.OnNext(1);