BossObservableExtension

public static class BossObservableExtension
{
	public static IObservable<T> Boss(this IObservable<T> source)
	{
		if(source == null) throw new ArgumentNullException("source");
		
		//前のオペレータがBossの時は何もしない重複回避処理
		if(source is BossObservable<T>)
		{
			return source;
		}
		
		return new BossObservable<T>(source);
	}
}