我試圖從一個(gè) Action 創(chuàng)建一個(gè) Observable，但是 andFromEventPattern語法FromEvent讓我很難理解。這是我的嘗試：Observable .FromEventPattern<Action<IStreamTrade>, IStreamTrade>( x => _polygonSocket.TradeReceived += x, x => _polygonSocket.TradeReceived -= x) .Select(x => x?.EventArgs) .IsNotNull() .Subscribe( /** do stuff **/) .DisposeWith(Bindings);我覺得FromEventPattern這里可能不是正確的選擇，但我無法編譯其他任何內(nèi)容。會(huì)發(fā)生什么：我收到一個(gè)Parameter count mismatch.異常，如下所示：Parameter count mismatch.Thread started: #26 at System.Delegate.CreateDelegate (System.Type type, System.Object firstArgument, System.Reflection.MethodInfo method, System.Boolean throwOnBindFailure, System.Boolean allowClosed) [0x000ee] in /Users/builder/jenkins/workspace/xamarin-macios/xamarin-macios/external/mono/mcs/class/corlib/System/Delegate.cs:230 at System.Delegate.CreateDelegate (System.Type type, System.Object firstArgument, System.Reflection.MethodInfo method) [0x00000] in /Users/builder/jenkins/workspace/xamarin-macios/xamarin-macios/external/mono/mcs/class/corlib/System/Delegate.cs:296 at System.Reactive.ReflectionUtils.CreateDelegate[TDelegate] (System.Object o, System.Reflection.MethodInfo method) [0x00000] in <370f6a6bb34048878534065376a195cb>:0 at System.Reactive.Linq.ObservableImpl.FromEventPattern+Impl`2[TDelegate,TEventArgs].GetHandler (System.Action`1[T] onNext) [0x0003d] in <370f6a6bb34048878534065376a195cb>:0 at System.Reactive.Linq.ObservableImpl.EventProducer`2+Session[TDelegate,TArgs].Initialize () [0x00023] in <370f6a6bb34048878534065376a195cb>:0 at System.Reactive.Linq.ObservableImpl.EventProducer`2+Session[TDelegate,TArgs].Connect (System.IObserver`1[T] observer) [0x00033] in <370f6a6bb34048878534065376a195cb>:0 我正在尋找什么：我想學(xué)習(xí)如何從Action<IStreamTrade>. 我對(duì)使用的解決方案持開放態(tài)度Observable.Create，但更喜歡使用FromEvent或的解決方案FromEventPattern（如果可能的話）。GitHub 源代碼
2 回答
ITMISS
TA貢獻(xiàn)1871條經(jīng)驗(yàn) 獲得超8個(gè)贊
嘗試使用Observable.FromEvent，它將通用的基于 Action 的 .NET 事件轉(zhuǎn)換為可觀察的序列：
Observable.FromEvent<IStreamTrade>(
x => _polygonSocket.TradeReceived += x,
x => _polygonSocket.TradeReceived -= x)
.Subscribe( /** do stuff **/)
.DisposeWith(Bindings);
繁星coding
TA貢獻(xiàn)1797條經(jīng)驗(yàn) 獲得超4個(gè)贊
雖然我更喜歡，并使用了維塔利的方法。這是使用的另一種方法Observable.Create。
Observable
.Create<IStreamTrade>(
x =>
{
Action<IStreamTrade> aist = st => x.OnNext(st);
_polygonSocket.TradeReceived += aist;
return Disposable.Create(() => _polygonSocket.TradeReceived -= aist);
})
.Subscribe()
.DisposeWith(Bindings);
- 2 回答
- 0 關(guān)注
- 190 瀏覽
添加回答
舉報(bào)
0/150
提交
取消