Providerクラスと継承元のDataProviderクラスを検証

今回は動作をテストしてみる。
検証用のコードは最後に。

検証用関数のcreateQP(string symbol)を呼んで
QuotesProviderのインスタンス生成と、それのイベント登録を行う

1. DataProvider.stateChanged
2. QuotesProvider.updated

QuotesProviderのfieldsにはlastとExchangeListedをセットしておく。とりあ。
createQPの引数であるsymbolを変えつつ、それぞれのハンドラ部分の結果をテスト。

まず、普通に
createQP("8798-TS");
印刷ログの結果は

----2019/03/17 21:01:07----
args.OldState.ToString() = loading
args.NewState.ToString() = loaded
sender.GetType().ToString() = tsdata.marketdata.QuotesProvider
objqp.Symbol = 8798
objqp.Quote["last"].doublevalue = 1714.00
initialupdate
objqp.Symbol = 8798
objqp.Quote["ExchangeListed"].stringValue = TSE

こうなる。

発火する順序は
1)DataProvider.stateChanged
2)QuotesProvider.updated
の順序で発火。

###DataProvider.stateChangedで取得できること
第二引数のtsdata.common.StateChangedEventArgs args によって
ステータスがloading から loadedに変わったことがわかる

また、第一引数senderで
発火元が tsdata.marketdata.QuotesProviderであること。
そして、発火元のsymbolプロパティが8798であることがわかる

最後に、ステータスがloadedであれば、senderを発火元のproviderにキャストすることで必要なQuotesプロパティを取得可能。

###QuotesProvider.updatedで取得できること
第二引数tsdata.marketdata.QuoteUpdatedEventArgs argsにて
updateイベントの発理由を取得できる　(InitialUpdate:1 , realtimeupdate:0)の2種類だ。

第一引数の扱いについてはDataProviderと変わらない。

###QuotesProvider.updateはDataProvider.stateChengedがloadedになってから発火する
存在しないsymbolデータでの取得テストではDataProviderstateChangeがfailedとなり、QuotesProvider.updatedは発火しない。

扱いの違いはこれだけ？と思う。
realtimeデータの受信がどうなるかわ今は日曜なので判別できないｓ・・

###検証用コード

using elsystem;
using elsystem.collections;
using tsdata.marketdata;
using tsdata.common;

var:Dictionary qpdic(null);	//生成したQuotesProviderを格納する入れ物


//デザイナージェネレーションコード :自動生成コード部（プログラムコピーしたときに忘れがちなのでじかに記述しておく
method override void InitializeComponent()
begin
		self.initialized += at_initialized;
		self.uninitialized += at_uninitialized;
end;
//デザイナージェネレーションコード END

method void AT_initialized( elsystem.Object sender, elsystem.InitializedEventArgs args ) 
begin

	qpdic = Dictionary.Create();

end;

method void AT_uninitialized( elsystem.Object sender, elsystem.UnInitializedEventArgs args ) 
begin
	clearprintlog();
end;

//与えられたsymbolごとにQuotesProviderインスタンスを生成
method void createQP(string strSymbol)
var: QuotesProvider qp ;
begin
	//初期値
	qp = null;
	try
		
		qp = new QuotesProvider;
		qp.Realtime = false;	//initialupdateのみでおｋなのでfalse
		qp.Symbol = strSymbol;
		qp.Fields = TokenList.create("ExchangeListed,last");
		
		qp.LoadProvider();
		{
		PriceDataStream オブジェクトがアップデートされると発生します。ハンドラーの args パラメーターが返すプロパティについては、「QuoteUpdatedEventArgs」を参照してください。
		}
		qp.Updated += self.QP_updated;
		qp.StateChanged += self.DataProvider_statechanged;
		
		qpdic.Add(strSymbol , qp);	//関数内ローカル変数であるQuotesProviderのインスタンスをDictionaryに入れてインスタンスを生存させる
		
	catch(elsystem.exception ex)
		print(strsymbol,ex.Message.ToString());
	end;
	
end;

//-----------------------------------------
//DataProviderのstatechangedイベントのハンドラ
//-----------------------------------------
method void DataProvider_statechanged( elsystem.Object sender, tsdata.common.StateChangedEventArgs args ) 
var:QuotesProvider objqp;
begin
	print(NewLine , "----" , datetime.now.ToString() , "----");
	print("args.OldState.ToString() = " , args.OldState.ToString());
	print("args.NewState.ToString() = " , args.NewState.ToString());	//tostring()必要
	print("sender.GetType().ToString() = " , sender.GetType().ToString());	//tsdata.marketdata.QuotesProvider
	
	objqp = sender astype QuotesProvider;
	print("objqp.Symbol = " , objqp.Symbol);
	if(args.NewState.ToString() = "loaded") then 
		print("objqp.Quote[",DoubleQuote,"last",DoubleQuote,"].doublevalue = " , objqp.Quote["last"].doublevalue);
	//stateがloadedになる前に呼び出すとエラー 
	//elsystem.InvalidOperationException:[プロバイダー]のデータは、オブジェクトが[ロード済み]になるまでアクセスできません。
end;


//-----------------------------------
//QuotesProviderのUPdatedイベントのはんどら
//-----------------------------------
method void QP_updated( elsystem.Object sender, tsdata.marketdata.QuoteUpdatedEventArgs args ) 
var:QuotesProvider objqp;
begin

	//updateイベントの発理由を取得できる　(InitialUpdate:1 , realtimeupdate:0)の2種類だ。
	print(args.Reason.ToString());
	
	//引数object senderをQuotesProviderにキャストすることで、QuotesProviderのデータを取得することができる。
	objqp = sender astype QuotesProvider;
	print("objqp.Symbol = " + objqp.Symbol);
	print("objqp.Quote[" + doubleQuote + "ExchangeListed" + doubleQuote + "].stringValue = " + objqp.Quote["ExchangeListed"].stringValue);
		

	//例えば、初回inisialUpdate時に閉じてしまえば、realtimeupdateの受信は発火しない（はず）
	//objqp.CloseProvider();
end;


method void test()
begin
	createQP("8798-TS");
	createQP("7203-TS");
	createQP("0000-TS");	//存在しないコード
	createQP("7048-TS");

end;

test();

###全テスト結果

----2019/03/17 21:18:36----
args.OldState.ToString() = loading
args.NewState.ToString() = loaded
sender.GetType().ToString() = tsdata.marketdata.QuotesProvider
objqp.Symbol = 8798-TS
objqp.Quote["last"].doublevalue = 1714.00
initialupdate
objqp.Symbol = 8798-TS
objqp.Quote["ExchangeListed"].stringValue = TSE

----2019/03/17 21:18:36----
args.OldState.ToString() = loading
args.NewState.ToString() = loaded
sender.GetType().ToString() = tsdata.marketdata.QuotesProvider
objqp.Symbol = 7203-TS
objqp.Quote["last"].doublevalue = 6615.00
initialupdate
objqp.Symbol = 7203-TS
objqp.Quote["ExchangeListed"].stringValue = TSE

----2019/03/17 21:18:36----
args.OldState.ToString() = loading
args.NewState.ToString() = loaded
sender.GetType().ToString() = tsdata.marketdata.QuotesProvider
objqp.Symbol = 7048-TS
objqp.Quote["last"].doublevalue = 1452.00
initialupdate
objqp.Symbol = 7048-TS
objqp.Quote["ExchangeListed"].stringValue = TSE

----2019/03/17 21:18:36----
args.OldState.ToString() = loading
args.NewState.ToString() = failed
sender.GetType().ToString() = tsdata.marketdata.QuotesProvider
objqp.Symbol = 0000-TS