code: def asyncPipeStringtokenizer(context=None, _INPUT=None, conf=None, **kwargs):
      conf['delimiter'] = conf.pop('to-str', dict.get(conf, 'delimiter'))
      splits = yield asyncGetSplits(_INPUT, conf, **cdicts(opts, kwargs))
      parsed = yield asyncDispatch(splits, *get_async_dispatch_funcs())
      items = yield asyncStarMap(partial(maybeDeferred, parse_result), parsed)
      _OUTPUT = utils.multiplex(items)
      returnValue(_OUTPUT)