Dart Documentation › objectory_impl › ObjectoryCollectionWebsocketBrowserImpl

ObjectoryCollectionWebsocketBrowserImpl class 

class ObjectoryCollectionWebsocketBrowserImpl extends ObjectoryCollection{
 ObjectoryWebsocketBrowserImpl objectoryImpl;
 ObjectoryCollectionWebsocketBrowserImpl(this.objectoryImpl);
 Future<int> count([ObjectoryQueryBuilder selector]) { 
   Completer completer = new Completer();
   if (selector == null) {
     selector = new ObjectoryQueryBuilder();
   }
   var obj;
   objectoryImpl._postMessage(objectoryImpl._createCommand('count', collectionName), selector.map, selector.extParamsMap)
     .then((int _count){
       completer.complete(_count); 
     });
    return completer.future; 
 }
 Future<List<PersistentObject>> find([ObjectoryQueryBuilder selector]){
   Completer completer = new Completer();
   if (selector == null) {
     selector = new ObjectoryQueryBuilder();
   }
   var result = objectory.createTypedList(classType);
   objectoryImpl._postMessage(objectoryImpl._createCommand('find',collectionName), selector.map, selector.extParamsMap).then((list) {
     for (var map in list) {
       PersistentObject obj = objectory.map2Object(classType,map);
       result.add(obj);
     }
     if (!selector.paramFetchLinks) {
       completer.complete(result);
     } else {
       Future
       .wait(result.map((item) => item.fetchLinks()))
       .then((res) {completer.complete(res);}); 
     }
   });
   return completer.future;
 }  
 
 Future<PersistentObject> findOne([ObjectoryQueryBuilder selector]){
   Completer completer = new Completer();
   if (selector == null) {
     selector = new ObjectoryQueryBuilder();
   }
   var obj;
   objectoryImpl._postMessage(objectoryImpl._createCommand('findOne',collectionName), selector.map, selector.extParamsMap)
   .then((map){
     objectoryImpl.completeFindOne(map,completer,selector, classType); 
   });
   return completer.future;
 }
}

Extends

ObjectoryCollection > ObjectoryCollectionWebsocketBrowserImpl

Constructors

new ObjectoryCollectionWebsocketBrowserImpl(ObjectoryWebsocketBrowserImpl objectoryImpl) #

Creates a new Object instance.

Object instances have no meaningful state, and are only useful through their identity. An Object instance is equal to itself only.

docs inherited from Object 
ObjectoryCollectionWebsocketBrowserImpl(this.objectoryImpl);

Properties

Type classType #

inherited from ObjectoryCollection 
Type classType

String collectionName #

inherited from ObjectoryCollection 
String collectionName

ObjectoryWebsocketBrowserImpl objectoryImpl # 

ObjectoryWebsocketBrowserImpl objectoryImpl

Methods

Future<int> count([ObjectoryQueryBuilder selector]) #

Future<int> count([ObjectoryQueryBuilder selector]) { 
 Completer completer = new Completer();
 if (selector == null) {
   selector = new ObjectoryQueryBuilder();
 }
 var obj;
 objectoryImpl._postMessage(objectoryImpl._createCommand('count', collectionName), selector.map, selector.extParamsMap)
   .then((int _count){
     completer.complete(_count); 
   });
  return completer.future; 
}

Future<List<PersistentObject>> find([ObjectoryQueryBuilder selector]) #

Future<List<PersistentObject>> find([ObjectoryQueryBuilder selector]){
 Completer completer = new Completer();
 if (selector == null) {
   selector = new ObjectoryQueryBuilder();
 }
 var result = objectory.createTypedList(classType);
 objectoryImpl._postMessage(objectoryImpl._createCommand('find',collectionName), selector.map, selector.extParamsMap).then((list) {
   for (var map in list) {
     PersistentObject obj = objectory.map2Object(classType,map);
     result.add(obj);
   }
   if (!selector.paramFetchLinks) {
     completer.complete(result);
   } else {
     Future
     .wait(result.map((item) => item.fetchLinks()))
     .then((res) {completer.complete(res);}); 
   }
 });
 return completer.future;
}

Future<PersistentObject> findOne([ObjectoryQueryBuilder selector]) #

Future<PersistentObject> findOne([ObjectoryQueryBuilder selector]){
 Completer completer = new Completer();
 if (selector == null) {
   selector = new ObjectoryQueryBuilder();
 }
 var obj;
 objectoryImpl._postMessage(objectoryImpl._createCommand('findOne',collectionName), selector.map, selector.extParamsMap)
 .then((map){
   objectoryImpl.completeFindOne(map,completer,selector, classType); 
 });
 return completer.future;
}

Future<PersistentObject> get(ObjectId id) #

inherited from ObjectoryCollection 
Future<PersistentObject> get(ObjectId id) => objectory.findInCacheOrGetProxy(id, this.classType).fetch();