Reactive extensions experts using c#

This project is now closed with a project budget of N/A.

Get free quotes for a project like this
Employer working
Skills Required
Project Budget
Project Description


Need to get following reactive queries developed -

Scenario - Three types of objects - GrandParent,Parent,Child

Test Scenario - Create 4 objects of each type


Parent- P11,P12,P13,P14,P21,P22,P23,P24,P31,P32,P41,P42

Child - C111,C112,C121,C122,C123,C121,C122,C123,C124,C131,C132,C141,C142 and so on

Relationship - GP1 is related to P11, P12,P13, P14 . Relationship from P to G is called "Parent"

P11 is related to C111,C112 Relationship from C to P is called "ParentOf" and relationship P to C is called "ChildOf"

( first number represent object of GrandParent, 2nd Parent, 3 is for child) .This is just sample (object name can be anything)

we have event -



string objectType;

string name;

string pc ;

string dc;

string reason;

int cond;


here cond=1 means active event

cond =2 mean event now inactive

Reactive Query Requirement (You are getting continuous stream of events, which can be corresponding to any type with any name or other properties)

Requirement 1-

a) If I recv events where pc= "CD" and cond=1 where objectType = "CHILD" for all the childs of a given parent during duration X sec, create a new event for corresponding parent with PC="PC" and cond =1, reason="CD", if during the duration X, if for anychild you recv pc=CD and cond=2 the scenario is no longer valid

b)If you recv a event with pc= "CD" and cond =2 for a child and during that time PC="PC" and cond =1, reason="CD" exist for its parent , wait for N sec, if during the time you recv a event with cond = 1 for the same child, do nothing, otherwise raise event PC="PC" and cond =2, reason="CD".

Consider following function, you can hardcode them

a)GetNodeCount(string NodeType,string NodeName,string RelationShipKind)

b)GetNodeRelation(string NodeType,string NodeName, string RelationShipKind) -

Example of function B call - if for child C1, i want to want to find a relation of kind ParentOf

the function call will look like GetNodeRelation("CHILD","C111", "ParentOf") it will give P11

Example of function A call - if I want to find number of child of the parent C1111 , i can use it like - GetNodeCount("PARENT",GetNodeRelation("CHILD","C111", "ParentOf") ,"CHILDOF")

c) RaiseEvent(AEvent evt) - The moment you raise it, on the next statement if you try function as mentioned in d, you will get 1.

d) GetExistingEventCount(string wherecondition) - this is to get count of events matching a given condition ; where condition is of like requlaer sql condition, like if i want to check if there exists a event with objecttype="CHILD" and name = "ABC" my where condtion will look like "objecttype='CHILD' and name = 'ABC'

Requirement 2

Its same as requirement 1, only difference is there is no constrain of time X there in point 1

Requirement 3

There is a Continuous influx of csv - csv is for the form (first line is header)

KeyCol1,KeyCol2,KeyCol3, Date, Time, D1,D2,D3,D4

Requirement - (Say GapTime is 15 minutes)

a) For each KeyColumn combination, output the different of last 2 values ( say you recvd 1st file at time 10:15 which has data for key1,Key2,Key3,Key4

then at 10:30 you got the 2nd file, at this time you will output key1,Key2,Key3,Key4,from 10:30 file(D1) - 10:15 (D1), 10:30 file (D2) - 10:15(d2)

and so on

and now you can relase 10:15 data for key1,key2,key3,key4 and keep 10:30 data for key1,Key2,Key3,Key4

if you never recvd 10:45 data, but directly recvd 11:00 data, then you dont output anything, just release 10:30 data and keep 11:00 data

Looking to make some money?

  • Set your budget and the timeframe
  • Outline your proposal
  • Get paid for your work

Hire Freelancers who also bid on this project

    • Forbes
    • The New York Times
    • Time
    • Wall Street Journal
    • Times Online