diff --git a/src/main/java/neqsim/processSimulation/processEquipment/util/Calculator.java b/src/main/java/neqsim/processSimulation/processEquipment/util/Calculator.java
index 65049fde2..7fb195026 100644
--- a/src/main/java/neqsim/processSimulation/processEquipment/util/Calculator.java
+++ b/src/main/java/neqsim/processSimulation/processEquipment/util/Calculator.java
@@ -71,10 +71,22 @@ public boolean needRecalculation() {
     return false;
   }
 
+  public void runAntiSurgeCalc(UUID id) {
+
+    for (int i = 0; i < inputVariable.size(); i++) {
+      // distance inputVariable.get;
+    }
+  }
+
+
   /** {@inheritDoc} */
   @Override
   public void run(UUID id) {
     double sum = 0.0;
+    if (name.equals("anti surge calculator")) {
+      runAntiSurgeCalc(id);
+      return;
+    }
 
     if (name.equals("MEG makeup calculator")) {
       for (int i = 0; i < inputVariable.size(); i++) {
diff --git a/src/test/java/neqsim/processSimulation/processSystem/OilGasProcessTest.java b/src/test/java/neqsim/processSimulation/processSystem/OilGasProcessTest.java
index 557bbdf03..aa6674529 100644
--- a/src/test/java/neqsim/processSimulation/processSystem/OilGasProcessTest.java
+++ b/src/test/java/neqsim/processSimulation/processSystem/OilGasProcessTest.java
@@ -11,6 +11,7 @@
 import neqsim.processSimulation.processEquipment.splitter.Splitter;
 import neqsim.processSimulation.processEquipment.stream.Stream;
 import neqsim.processSimulation.processEquipment.stream.StreamInterface;
+import neqsim.processSimulation.processEquipment.util.Calculator;
 import neqsim.processSimulation.processEquipment.util.Recycle;
 import neqsim.processSimulation.processEquipment.valve.ThrottlingValve;
 import neqsim.thermo.system.SystemInterface;
@@ -185,6 +186,10 @@ public void runAntiSurgeProcess() throws InterruptedException {
     recycl.setOutletStream(recyclegasstream);
     recycl.run();
 
+    Calculator antisurgeCalculator = new Calculator("anti surge calculator");
+    antisurgeCalculator.addInputVariable(gascompressor);
+    antisurgeCalculator.setOutputVariable(gassplitter);
+
     neqsim.processSimulation.processSystem.ProcessSystem operations =
         new neqsim.processSimulation.processSystem.ProcessSystem();
     operations.add(gas_from_separator);
@@ -195,6 +200,7 @@ public void runAntiSurgeProcess() throws InterruptedException {
     operations.add(gassplitter);
     operations.add(antisurgevalve);
     operations.add(recycl);
+    operations.add(antisurgeCalculator);
     operations.run();
 
     assertEquals(6.9999999, gassplitter.getSplitStream(0).getFlowRate("MSm3/day"), 1e-4);