def METHOD_NAME(pcoll, negatives):
  first_output = (
      pcoll
      | 'process numbers step 1' >> ParDo(ProcessNumbersFn(), negatives))
  second_output = (
      first_output
      | 'process numbers step 2' >> ParDo(ProcessNumbersFn(), negatives))
  output_pc = ((first_output, second_output)
               | 'flatten results' >> beam.Flatten())
  return output_pc