protected function processPipeObject(object $pipe, $payload)
    {
        if (!$pipe instanceof PipeInterface) {
            throw new MissingPipeInterfaceException(get_class($pipe));
        }
        return $pipe($payload);
    }