package foam.dao;

import foam.core.Detachable;
import foam.core.FObject;
import foam.core.X;
import foam.mlang.order.Comparator;
import foam.mlang.predicate.Predicate;

public class RemoveSink implements Sink {

  protected DAO dao;

  public RemoveSink(DAO dao) {
    dao = dao;
  }

  @Override
  public void put(FObject obj, Detachable sub) {
    final X x = ((AbstractDAO) dao).getX();
    dao.remove_(x, obj);
  }

  @Override
  public void remove(FObject obj, Detachable sub) {

  }

  @Override
  public void eof() {

  }

  @Override
  public void reset(Detachable sub) {

  }
}

@@ -263,16 +263,21 @@
 ) %7B%0A    
+this.
 dao = da
@@ -376,16 +376,21 @@
 actDAO) 
+this.
 dao).get
@@ -398,16 +398,21 @@
 ();%0A    
+this.
 dao.remo

fix scope