Gardient/behavioral-patterns
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Replace var with actual code so that people can see that it's observable, not observer

Browse Source 
Update Observer pattern description/ State pattern description
This commit is contained in:
Petrutiu Mihai
2016-07-13 12:45:40 +03:00
parent 5a2705af49
commit e5b5fc1a51
2 changed files with 72 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/ObserverPattern/StockUpdateEvents/StockUpdateEventsExample.cs
View File

@@ -25,16 +25,16 @@ namespace ObserverPattern.StockUpdateEvents
{
StockSubject stockSubject = new StockSubject();
var londonObserver = Observable.FromEventPattern<StockUpdateEventArgs>(
IObservable<EventPattern<StockUpdateEventArgs>> londonObservable = Observable.FromEventPattern<StockUpdateEventArgs>(
ev => stockSubject.StockUpdated += ev,
ev => stockSubject.StockUpdated -= ev).Where(s => s.EventArgs.Stock.Name == "FTSE");
var aaplObserver = Observable.FromEventPattern<StockUpdateEventArgs>(
IObservable<EventPattern<StockUpdateEventArgs>> aaplObservable = Observable.FromEventPattern<StockUpdateEventArgs>(
ev => stockSubject.StockUpdated += ev,
ev => stockSubject.StockUpdated -= ev).Where(s => s.EventArgs.Stock.Name == "AAPL");
using (londonObserver.Subscribe(PrintLondonStockPriceUpdate))
using (aaplObserver.Subscribe(PrintAaplStockPriceUpdate))
using (londonObservable.Subscribe(PrintLondonStockPriceUpdate))
using (aaplObservable.Subscribe(PrintAaplStockPriceUpdate))
{
PublishUpdateStocks(stockSubject);
}
@@ -44,11 +44,11 @@ namespace ObserverPattern.StockUpdateEvents
{
Subject<Stock> stockSubject = new Subject<Stock>();
var londonObserver = stockSubject.Where(s => s.Name == "FTSE");
var aaplObserver = stockSubject.Where(s => s.Name == "AAPL");
IObservable<Stock> londonObservable = stockSubject.Where(s => s.Name == "FTSE");
IObservable<Stock> aaplObservable = stockSubject.Where(s => s.Name == "AAPL");
using (londonObserver.Subscribe(PrintLondonStockPriceUpdate))
using (aaplObserver.Subscribe(PrintAaplStockPriceUpdate))
using (londonObservable.Subscribe(PrintLondonStockPriceUpdate))
using (aaplObservable.Subscribe(PrintAaplStockPriceUpdate))
{
PublishUpdateStocks(stockSubject);
}