code: func (e *edge) postpone(f *pipeFactory) {
  	f.NewFuncRequest(func(context.Context) (interface{}, error) {
  		return nil, nil
  	})
  }
docs: // postpone delays exec to next unpark invocation if we have unprocessed keys