Method on_objects_removed

libraries/app/database_api.cpp:1443–1482

}

void database_api_impl::on_objects_removed( const vector<const object*>& objs )
{
   /// we need to ensure the database_api is not deleted for the life of the async operation
   if( _subscribe_callback )
   {
      vector<variant>    updates;
      updates.reserve(objs.size());

      for( auto obj : objs )
         updates.emplace_back( obj->id );
      broadcast_updates( updates );
   }

   if( _market_subscriptions.size() )
   {
      map< pair<asset_id_type, asset_id_type>, vector<variant> > broadcast_queue;
      for( const auto& obj : objs )
      {
         const limit_order_object* order = dynamic_cast<const limit_order_object*>(obj);
         if( order )
         {
            auto sub = _market_subscriptions.find( order->get_market() );
            if( sub != _market_subscriptions.end() )
               broadcast_queue[order->get_market()].emplace_back( order->id );
         }
      }
      if( broadcast_queue.size() )
      {
         auto capture_this = shared_from_this();
         fc::async([capture_this,this,broadcast_queue](){
             for( const auto& item : broadcast_queue )
             {
               auto sub = _market_subscriptions.find(item.first);
               if( sub != _market_subscriptions.end() )
                   sub->second( fc::variant(item.second ) );
             }
         });
      }
   }
}

void database_api_impl::on_objects_changed(const vector<object_id_type>& ids)
{