Sample 2 - Collector

SqlStatementCollector.cs

public class SqlStatementCollector : IObserver<ISqlStatement> {
  List<ISqlStatement> _statements;

  public SqlStatementCollector() {
    _statements = new List<ISqlStatement>();
  }

  public ISqlStatement[] CollectedStatements {
    get {
      return _statements.ToArray();
    }
  }

  public void OnNext(ISqlStatement value) {
    _statements.Add(value);
  }

  public void OnError(Exception error) { }

  public void OnCompleted() { }
}