anchor.diff:  
     final StreamController<WebSocketEvent> _onAllEvents =
         new StreamController<WebSocketEvent>();
  -  final StreamController _onIndexed = new StreamController();
  +  final StreamController<List<Data>> _onIndexed = new StreamController();
     final StreamController<Data> _onRead = new StreamController<Data>();
     final StreamController<Data> _onCreated = new StreamController<Data>();
     final StreamController<Data> _onModified = new StreamController<Data>();
  
positive.code:   Stream<WebSocketEvent> get onAllEvents => _onAllEvents.stream;
  
    /// Fired on `index` events.
    Stream get onIndexed => _onIndexed.stream;
  
    /// Fired on `read` events.
    Stream<Data> get onRead => _onRead.stream;
  
negative.code:   }
  
    @override
    Future<Data> remove(id, [Map<String, dynamic> params]) async {
      app.sendAction(new WebSocketAction(
          eventName: '$path::${ACTION_REMOVE}',
          id: id.toString(),
  