Dart Documentation › mongo_dart › MongoReplyMessage

MongoReplyMessage class 

class MongoReplyMessage extends MongoMessage{
 BsonCString _collectionFullName;
 int responseFlags;
 int cursorId =-1; // 64bit integer
 int startingFrom;
 int numberReturned = -1;
 List documents;
 deserialize(BsonBinary buffer){
   readMessageHeaderFrom(buffer);
   responseFlags = buffer.readInt32();
   cursorId = buffer.readInt64();
   startingFrom = buffer.readInt32();
   numberReturned = buffer.readInt32();
   documents = new List(numberReturned);
   for (int n=0;n<numberReturned;n++){
     BsonMap doc = new BsonMap({});
     doc.unpackValue(buffer);
     documents[n] = doc.value;
   }
 }
 String toString(){
   if (documents.length == 1)
   {
     return "MongoReplyMessage(ResponseTo:$responseTo, cursorId: $cursorId, numberReturned:$numberReturned, responseFlags:$responseFlags, ${documents[0]})";
   }
   return "MongoReplyMessage(ResponseTo:$responseTo, cursorId: $cursorId, numberReturned:$numberReturned, responseFlags:$responseFlags,$documents)";
 }

}

Extends

MongoMessage > MongoReplyMessage

Properties

int cursorId # 

int cursorId =-1

List documents # 

List documents

final int messageLength #

inherited from MongoMessage 
int get messageLength{
 throw new MongoDartError('Must be implemented');
}

int numberReturned # 

int numberReturned = -1

int opcode #

inherited from MongoMessage 
int opcode = MongoMessage.Reply

final int requestId #

inherited from MongoMessage 
int get requestId{
 if (_requestId == null){
   _requestId = _Statics.nextRequestId;
 }
 return _requestId;
}

int responseFlags # 

int responseFlags

int responseTo #

inherited from MongoMessage 
int responseTo

int startingFrom # 

int startingFrom

Methods

dynamic deserialize(BsonBinary buffer) #

deserialize(BsonBinary buffer){
 readMessageHeaderFrom(buffer);
 responseFlags = buffer.readInt32();
 cursorId = buffer.readInt64();
 startingFrom = buffer.readInt32();
 numberReturned = buffer.readInt32();
 documents = new List(numberReturned);
 for (int n=0;n<numberReturned;n++){
   BsonMap doc = new BsonMap({});
   doc.unpackValue(buffer);
   documents[n] = doc.value;
 }
}

dynamic readMessageHeaderFrom(BsonBinary buffer) #

inherited from MongoMessage 
readMessageHeaderFrom(BsonBinary buffer)
{
   _messageLength = buffer.readInt32();
   _requestId = buffer.readInt32();
   responseTo = buffer.readInt32();
   int opcodeFromWire = buffer.readInt32();
   if (opcodeFromWire != opcode)
   {
       throw new MongoDartError('Expected $opcode in Message header. Got $opcodeFromWire');
   }
}

BsonBinary serialize() #

inherited from MongoMessage 
BsonBinary serialize(){
 throw new MongoDartError('Must be implemented');
}

String toString() #

Returns a string representation of this object.

docs inherited from Object 
String toString(){
 if (documents.length == 1)
 {
   return "MongoReplyMessage(ResponseTo:$responseTo, cursorId: $cursorId, numberReturned:$numberReturned, responseFlags:$responseFlags, ${documents[0]})";
 }
 return "MongoReplyMessage(ResponseTo:$responseTo, cursorId: $cursorId, numberReturned:$numberReturned, responseFlags:$responseFlags,$documents)";
}

dynamic writeMessageHeaderTo(BsonBinary buffer) #

inherited from MongoMessage 
writeMessageHeaderTo(BsonBinary buffer)
{
   buffer.writeInt(messageLength); // messageLength will be backpatched later
   buffer.writeInt(requestId);
   buffer.writeInt(0); // responseTo not used in requests sent by client
   buffer.writeInt(opcode);
   if (messageLength < 0){
     throw new MongoDartError('Error in message length');
   }
}