件名<T>.Subscribe メソッド
オブザーバーをサブジェクトにサブスクライブします。
Namespace:System.Reactive.Subjects
アセンブリ： System.Reactive (System.Reactive.dll)
構文
'Declaration
Public Function Subscribe ( _
observer As IObserver(Of T) _
) As IDisposable
'Usage
Dim instance As Subject
Dim observer As IObserver(Of T)
Dim returnValue As IDisposable
returnValue = instance.Subscribe(observer)
public IDisposable Subscribe(
IObserver<T> observer
)
public:
virtual IDisposable^ Subscribe(
IObserver<T>^ observer
) sealed
abstract Subscribe :
observer:IObserver<'T> -> IDisposable
override Subscribe :
observer:IObserver<'T> -> IDisposable
public final function Subscribe(
observer : IObserver<T>
) : IDisposable
パラメーター
- オブザーバー
種類: System.IObserver<T>
件名をサブスクライブするオブザーバー。
戻り値
種類: System.IDisposable
オブザーバーをサブジェクトからサブスクライブ解除するために使用できる IDisposable オブジェクト。
実装
IObservable<T>.Subscribe(IObserver<T>)
例
この例では、サブジェクト クラスの使用方法を示します。 文字列型の Subject のインスタンスは、2 つのニュース フィードの例をサブスクライブするために使用されます。 これらのフィードは、5 秒以下の間隔でランダムなニュースの見出しを公開するだけです。 その後、サブジェクトの監視可能なインターフェイスに対して 2 つのサブスクリプションが作成され、結合されたデータ ストリームが受信されます。 1 つのサブスクリプションで、データ ストリームの各項目が "すべてのニュース" として報告されます。 他のサブスクリプションでは、ストリーム内の各見出しがフィルター処理され、ローカルの見出しのみがレポートされます。 サブスクリプションは両方とも、受信した各見出しをコンソール ウィンドウに書き込みます。 ユーザーが Enter キーを押すと処理が終了し、Dispose が呼び出されて両方のサブスクリプションが取り消されます。
using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Reactive.Concurrency;
using System.Threading;
namespace Example
{
class Program
{
static void Main()
{
//*****************************************************************************************************//
//*** ***//
//*** A subject acts similar to a proxy in that it acts as both a subscriber and a publisher ***//
//*** It's IObserver interface can be used to subscribe to multiple streams or sequences of data. ***//
//*** The data is then published through it's IObservable interface. ***//
//*** ***//
//*** In this example a simple string based subject is used to subscribe to multiple news feeds ***//
//*** that provide random news headlines. Subscribers can then subscribe to the subject's ***//
//*** observable interface to observe the data stream(s) or a subset ofthe stream(s). Below we ***//
//*** subscribe the subject to two different news headline feeds. Then two subscriptions are ***//
//*** created: one for delivery of all news headlines, the other receives only local news headlines ***//
//*** ***//
//*** A local news headline just contains the newsLocation substring ("in your area."). ***//
//*** ***//
//*****************************************************************************************************//
Subject<string> mySubject = new Subject<string>();
//*********************************************************//
//*** Create news feed #1 and subscribe mySubject to it ***//
//*********************************************************//
NewsHeadlineFeed NewsFeed1 = new NewsHeadlineFeed("Headline News Feed #1");
NewsFeed1.HeadlineFeed.Subscribe(mySubject);
//*********************************************************//
//*** Create news feed #2 and subscribe mySubject to it ***//
//*********************************************************//
NewsHeadlineFeed NewsFeed2 = new NewsHeadlineFeed("Headline News Feed #2");
NewsFeed2.HeadlineFeed.Subscribe(mySubject);
Console.WriteLine("Subscribing to news headline feeds.\n\nPress ENTER to exit.\n");
//*****************************************************************************************************//
//*** Create a subscription to the subject's observable sequence. This subscription will receive ***//
//*** all headlines. ***//
//*****************************************************************************************************//
IDisposable allNewsSubscription = mySubject.Subscribe(x =>
{
Console.WriteLine("Subscription : All news subscription\n{0}\n", x);
});
//*****************************************************************************************************//
//*** Create a subscription to the subject's observable sequence. This subscription will filter for ***//
//*** only local headlines. ***//
//*****************************************************************************************************//
IDisposable localNewsSubscription = mySubject.Where(x => x.Contains("in your area.")).Subscribe(x =>
{
Console.WriteLine("\n************************************\n" +
"***[ Local news headline report ]***\n" +
"************************************\n{0}\n\n", x);
});
Console.ReadLine();
//*********************************//
//*** Cancel both subscriptions ***//
//*********************************//
allNewsSubscription.Dispose();
localNewsSubscription.Dispose();
}
}
//*********************************************************************************//
//*** The NewsHeadlineFeed class is just a mock news feed in the form of an ***//
//*** observable sequence in Reactive Extensions. ***//
//*********************************************************************************//
class NewsHeadlineFeed
{
private string feedName; // Feedname used to label the stream
private IObservable<string> headlineFeed; // The actual data stream
private readonly Random rand = new Random(); // Used to stream random headlines.
//*** A list of predefined news events to combine with a simple location string ***//
static readonly string[] newsEvents = { "A tornado occurred ",
"Weather watch for snow storm issued ",
"A robbery occurred ",
"We have a lottery winner ",
"An earthquake occurred ",
"Severe automobile accident "};
//*** A list of predefined location strings to combine with a news event. ***//
static readonly string[] newsLocations = { "in your area.",
"in Dallas, Texas.",
"somewhere in Iraq.",
"Lincolnton, North Carolina",
"Redmond, Washington"};
public IObservable<string> HeadlineFeed
{
get { return headlineFeed; }
}
public NewsHeadlineFeed(string name)
{
feedName = name;
//*****************************************************************************************//
//*** Using the Generate operator to generate a continous stream of headline that occur ***//
//*** randomly within 5 seconds. ***//
//*****************************************************************************************//
headlineFeed = Observable.Generate(RandNewsEvent(),
evt => true,
evt => RandNewsEvent(),
evt => { Thread.Sleep(rand.Next(5000)); return evt; },
Scheduler.ThreadPool);
}
//****************************************************************//
//*** Some very simple formatting of the headline event string ***//
//****************************************************************//
private string RandNewsEvent()
{
return "Feedname : " + feedName + "\nHeadline : " + newsEvents[rand.Next(newsEvents.Length)] +
newsLocations[rand.Next(newsLocations.Length)];
}
}
}
コード例を使用して、次の出力が生成されました。
Subscribing to news headline feeds.
Press ENTER to exit.
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : A robbery occurred somewhere in Iraq.
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : An earthquake occurred in Dallas, Texas.
Subscription : All news subscription
Feedname : Headline News Feed #1
Headline : We have a lottery winner in your area.
**********************************[ ローカルニュースの見出しレポート ]********************************** フィード名: ヘッドラインニュースフィード #1 ヘッドライン:私たちはあなたの地域で宝くじの勝者を持っています。
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : Severe automobile accident Redmond, Washington
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : We have a lottery winner in Dallas, Texas.
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : An earthquake occurred in Dallas, Texas.
Subscription : All news subscription
Feedname : Headline News Feed #1
Headline : We have a lottery winner somewhere in Iraq.
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : Severe automobile accident somewhere in Iraq.
Subscription : All news subscription
Feedname : Headline News Feed #2
Headline : An earthquake occurred in your area.
**********************************[ ローカルニュースの見出しレポート ]********************************** フィード名: 見出しニュースフィード #2 見出し: あなたの地域で地震が発生しました。