 
     sendReadMessage: (name, query, callback) ->
       socket.emit "LiveDocumentRead", name, query, requestCallbackNonce
-      socket.on "LiveDocument" + requestCallbackNonce, callback
+      socket.on "LiveDocument" + requestCallbackNonce, (docs) ->
+        if _.isArray(docs)
+          _.each(docs, callback)
+        else
+          callback docs
       requestCallbackNonce += 1
 
     # **sendCreateMessage** *private*

requestCallbackNonce = 0
define ["underscore", "lib/inflection", "lib/socket"], (_, inflect, socket) ->
  
  _.mixin(inflect)
  classes = {}

    # _callback_: Function to call once read is complete, first argument is a
    # list of documents matching query.

    read: (query) ->
      emitter = new EventEmitter()
      @sendReadMessage _(_(@name).pluralize()).uncapitalize(), query, (document) =>
        emitter.emit "insert", document
      return emitter

   
    # **create** *public*
    # 
