def <<(object)
      raise StandardError.new('Pipeline is currently closed') if @pool.nil?
      object = @filters.apply_filters(object)
      if(object)
        object.freeze
        @pool.process{ flush(object) }
      end
    end
def <<(object)
      raise StandardError.new('Pipeline is currently closed') if @pool.nil?
      object = @filters.apply_filters(object)
      if(object)
        object.freeze
        @pool.process{ flush(object) }
      end
    end
object:: Object to send down the pipeline
 Send an object down the pipeline