Interface AsyncObservationPipe<I extends Observation,​O extends Observation>