code: def asyncPipeRegex(context=None, _INPUT=None, conf=None, **kwargs):
      
      splits = yield asyncGetSplits(_INPUT, conf['RULE'], **cdicts(opts, kwargs))
      asyncConvert = partial(maybeDeferred, convert_func)
      asyncFuncs = get_async_dispatch_funcs('pass', asyncConvert)
      parsed = yield asyncDispatch(splits, *asyncFuncs)
      _OUTPUT = yield maybeDeferred(parse_results, parsed)
      returnValue(iter(_OUTPUT))
docs: An operator that asynchronously replaces text in items using regexes.
      Each has the general format: "In [field] replace [match] with [replace]".
      Not loopable.
  
      Parameters
      ----------
      context : pipe2py.Context object
      _INPUT : asyncPipe like object (twisted Deferred iterable of items)
      conf : {
          'RULE': [
              {
                  'field': {'value': <'search field'>},
                  'match': {'value': <'regex'>},
                  'replace': {'value': <'replacement'>},
                  'globalmatch': {'value': '1'},
                  'singlelinematch': {'value': '2'},
                  'multilinematch': {'value': '4'},
                  'casematch': {'value': '8'}
              }
          ]
      }
  
      Returns
      -------
      _OUTPUT : twisted.internet.defer.Deferred generator of items