yuta-kaseda

public class BossObservable<T> : OperatorObservableBase<T>
{
	readonly IObservable<T> source;

	public BossObservable(
		IObservable<T> source)
		: base(source.IsRequiredSubscribeOnCurrentThread())
	{
		this.source = source;
	}