mapper.toEvent(address, timeZone, pdu)
.flatMapCompletable(vesEventNotifier::notifyEvents)
.doOnSubscribe(result -> LOG.debug("SNMP Trap processing started"))
.doOnComplete(() -> LOG.debug("SNMP Trap processed successfully"))
mapper.toEvent(address, timeZone, pdu)
.flatMapCompletable(vesEventNotifier::notifyEvents)
.doOnSubscribe(result -> LOG.debug("SNMP Trap processing started"))
.doOnComplete(() -> LOG.debug("SNMP Trap processed successfully"))