mantis-rxcontrol/src/main/java/io/mantisrx/control/IController.java [45:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public Subscriber<? super Double> call(final Subscriber<? super Double> s) {

    return new Subscriber<Double>(s) {
      @Override
      public void onCompleted() {
        if (!s.isUnsubscribed()) {
          s.onCompleted();
        }
      }

      @Override
      public void onError(Throwable t) {
        if (!s.isUnsubscribed()) {
          s.onError(t);
        }
      }

      @Override
      public void onNext(Double error) {
        Double controlAction = parent.processStep(error);
        if (!s.isUnsubscribed()) {
          s.onNext(controlAction);
        }
      }
    };
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/Controller.java [38:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Subscriber<? super Double> call(final Subscriber<? super Double> s) {

        return new Subscriber<Double>(s) {
            @Override
            public void onCompleted() {
                if (!s.isUnsubscribed()) {
                    s.onCompleted();
                }
            }

            @Override
            public void onError(Throwable t) {
                if (!s.isUnsubscribed()) {
                    s.onError(t);
                }
            }

            @Override
            public void onNext(Double error) {
                Double controlAction = parent.processStep(error);
                if (!s.isUnsubscribed()) {
                    s.onNext(controlAction);
                }
            }
        };
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -