mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java [66:90]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    .filter((T t1) -> t1 != null)
                    .doOnSubscribe(() -> {
                        logger.info("Subscription is ACTIVE for observable trigger with name: " + name);
                        subscriptionActive.increment();
                    })
                    .doOnUnsubscribe(() -> {
                        logger.info("Subscription is INACTIVE for observable trigger with name: " + name);
                        subscriptionActive.decrement();
                    })
                    .subscribe(
                        (T data) -> queue.write(data),
                        (Throwable e) -> {
                            logger.warn("Observable used to push data errored, on server with name: " + name, e);
                            if (doOnError != null) {
                                doOnError.call(e);
                            }
                        },
                        () -> {
                            logger.info("Observable used to push data completed, on server with name: " + name);
                            if (doOnComplete != null) {
                                doOnComplete.call();
                            }
                        }
                    )
            );
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java [122:146]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        .filter((T t1) -> t1 != null)
                        .doOnSubscribe(() -> {
                            logger.info("Subscription is ACTIVE for observable trigger with name: " + name);
                            subscriptionActive.increment();
                        })
                        .doOnUnsubscribe(() -> {
                            logger.info("Subscription is INACTIVE for observable trigger with name: " + name);
                            subscriptionActive.decrement();
                        })
                        .subscribe(
                            (T data) -> queue.write(data),
                            (Throwable e) -> {
                                logger.warn("Observable used to push data errored, on server with name: " + name, e);
                                if (doOnError != null) {
                                    doOnError.call(e);
                                }
                            },
                            () -> {
                                logger.info("Observable used to push data completed, on server with name: " + name);
                                if (doOnComplete != null) {
                                    doOnComplete.call();
                                }
                            }
                        )
        );
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -