Sample 2

PushBasedProjectionSqlOperations.cs

public class PushBasedProjectionSqlOperations<TProjection> :
  IProjectionSqlOperations<TProjection> {

  IObserver<ISqlStatement> _observer;
  ISqlStatementFactory _factory;

  public PushBasedProjectionSqlOperations(
    IObserver<ISqlStatement> observer,
    ISqlStatementFactory factory) {
    _observer = observer;
    _factory = factory;
  }

  public void Insert(TProjection item) {
    _observer.OnNext(
      _factory.NewInsertStatement<TProjection>(item));
  }

  public void Delete(Expression<Func<TProjection, bool>> @where) {
    _observer.OnNext(
       _factory.NewDeleteStatementWhere<TProjection>(@where));
  }
}