Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
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);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment