A C# class for processing inputs asynchronously using observables.