// https://stackoverflow.com/questions/72558093/in-rx-net-how-do-i-make-a-subject-to-resemble-taskcompletionsource-behavior#comment128663291_72558093

​

using System;

using System.Reactive;

using System.Reactive.Subjects;

​

var asyncSubj = new AsyncSubject<int>();

asyncSubj.Subscribe(x => Console.WriteLine(x));

​

Console.WriteLine("Emitting");

asyncSubj.OnNext(42);

Console.WriteLine("Completing");

asyncSubj.OnCompleted();

​

asyncSubj.Subscribe(x => Console.WriteLine(x));

asyncSubj.Subscribe(x => Console.WriteLine(x));

asyncSubj.Subscribe(x => Console.WriteLine(x));

​