code: public void close()
      {
      IOUtils.closeQuietly( source_);
      try
        {
        complete();
        }
      catch( Exception e)
        {
        logger_.error( "Can't complete filtering", e);
        }
      }
docs: Terminates filter output.