Databases
StackOverflow2013
Postsdbo
PO
 

Note that there are some explanatory texts on larger screens.

plurals
  1. PO
    primarykey
    data
    text
    <p>I think, if you are receiving a list of entities from each REST call, your call should have a little different signature - you are not observing each value in the return collection, you are observing the event of the call completion. So for airports, it should have the signature:</p> <pre><code>public IObservable&lt;Aiports&gt; GetAirports() </code></pre> <p>The next step would be to run first three in parallel and wait on all of them:</p> <pre><code>var ports_lines_statuses = Observable.ForkJoin(GetAirports(), GetAirlines(), GetStatuses()); </code></pre> <p>The third step woul be to compose the above abservable with the GetFlights():</p> <pre><code>var decoratedFlights = from pls in ports_lines_statuses let airport = MyAirportFunc(pls) from flight in GetFlights(airport) select flight; </code></pre> <p>EDIT: I still do not understand why your services return </p> <pre><code>IObservable&lt;Airport&gt; </code></pre> <p>instead of </p> <pre><code>IObservable&lt;IEnumerable&lt;Airport&gt;&gt; </code></pre> <p>AFAIK, from the REST call you get all entities at once - but maybe you do paging? Anyway, if you want RX do the buffering you could use .BufferWithCount() :</p> <pre><code> var allAirports = new AirportNamesService() .GetAirports().BufferWithCount(int.MaxValue); ... </code></pre> <p>Then you can apply ForkJoin:</p> <pre><code>var ports_lines_statuses = allAirports .ForkJoin(allAirlines, PortsLinesSelector) .ForkJoin(statuses, ... </code></pre> <p>ports_lines_statuses would contain a single event on the timeline which would contain all the reference data.</p> <p>EDIT: Here's another one, using the freshly minted ListObservable (latest release only):</p> <pre><code>allAiports = airports.Start(); allAirlines = airlines.Start(); allStatuses = statuses.Start(); ... whenReferenceDataLoaded = Observable.Join(airports.WhenCompleted() .And(airlines.WhenCompleted()) .And(statuses.WhenCompleted()) Then((p, l, s) =&gt; new Unit())); public static IObservable&lt;Unit&gt; WhenCompleted&lt;T&gt;(this IObservable&lt;T&gt; source) { return source .Materialize() .Where(n =&gt; n.Kind == NotificationKind.OnCompleted) .Select(_ =&gt; new Unit()); } </code></pre>
    singulars
    1. This table or related slice is empty.
    1. POCreating a REST client API using Reactive Extensions (Rx)
      singulars
      1. PTQuestion
    1. PTAnswer
    1. USSergey Aldoukhov
    1. USSergey Aldoukhov
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. POCreating a REST client API using Reactive Extensions (Rx)
      singulars
      1. PTQuestion
    1. This table or related slice is empty.
    1. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    2. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTAcceptedByOriginator
    3. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    1. COI actually do want to get all Airlines, Airports and Statuses in "one batch" first, because when I get Flights I need those three reference data sets to be present so that I can link them to a Flight. So I need to get Airports into a dict like this Dictionart<string, Airport>, so that I can do: flight.Airport = airports[flightXml.AirportCode].
      singulars
      1. PO
      1. USJonas Follesø
    2. COI updated the question with new method signatures. You where right, I actually do want to get all Airports, Airlines and Statuses at once. Am I correct in PortLinesSelector is a method combining airports and airlines, and then I need a second method to combine the previous result with then ew result? I tried downloading the latest release of RX for Silverlight 3/4, but couldn't find method Start() on Observable (only start with).
      singulars
      1. PO
      1. USJonas Follesø
    3. CO@jonas-folleso Yes, PortsLinesSelector is something like (ports, lines) => new { ports, lines }, and the second selector would attach the third result to this one. The idea here is to try to keep to the functional style as much as possible and just pass the data through the pipeline instead of using the local variables. Start() on observable is only on .Net4 release, so you would have to wait till it is ported to others...
      singulars
      1. PO
      1. USSergey Aldoukhov
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload