Rx Observable Function Call

Rx.observable.function.call.js

function fetchDataFromDatabase(query) {
  
  // Calling iOS method here
  
  Rx
    .Observable
    .create(function subscribe(observer) {
      // This will be called by the iOS client
      didReceiveDataFromDatabase = function(data) {
        // Parse, process your data if needed.
        observer.next(JSON.parse(data));
      }
    })
    .subscribe(result => {
      // Receiving data here
    });
}