rx
rx copied to clipboard
lempiji
Reactive Extensions for D Programming Language
How can I create an observable pipeline that runs continuously. It'll wait for input, process it and keep running. Wait for another input, process and keep waiting until and tell...
With every version > 0.10.1 I get a very strange casting error I don't understand: ``` alias typeof(windows_message_streams[WM_MOUSEMOVE].filter!(win => (win.wParam & MK_LBUTTON))) WM_MOUSEMOVE_LBUTTON_TYPE; WM_MOUSEMOVE_LBUTTON_TYPE WM_MOUSEMOVE_LBUTTON_STREAM; pragma(msg,typeof(WM_MOUSEMOVE_LBUTTON_STREAM)); pragma(msg,WM_MOUSEMOVE_LBUTTON_TYPE.sizeof); >> FilterObservable!(__lambda39, SubjectObject!(OS_State))...
I have a sequence that takes (x,y) coordinates. Now I want to notify only subscribes which pass a hit-test for this coordinate. How can this be done? All algorithms are...
makeObserver uses a `static struct AnonymouseObserver{...}`which, from my understanding, means that there is only one instance of this struct per thread. Hence, when I do this: ``` foreach(thing; myThings){ myMasterThing.subscribe(...
There exists: ```` auto makeObserver(E)(void delegate(E) doPut, void delegate() doCompleted, void delegate(Exception) doFailure) auto makeObserver(E)(void delegate(E) doPut, void delegate() doCompleted) auto makeObserver(E)(void delegate(E) doPut, void delegate(Exception) doFailure) ```` Since every...
Am I right that rx uses threads? Is every observer running in its own thread? What other threads do exists?
When using observers, is there a way to access the underlying object implementing the observer? ```` class myClass {...} myClass mc = new myClass; auto observer1 = makeObserver(&mc.myPut); ```` How...
I think what you have created is pretty cool and way under-recognized in the D community. The code base is not easy to understand (at least not for a casual...
Let's assume I have many steams (500) & observables (10000). The steams filter a couple of external message streams into more specific ones. How does rx scale? Are there are...