Class ActionPipe<O extends Observation>