diff --git a/pitest/src/main/java/org/pitest/coverage/CoverageReceiver.java b/pitest/src/main/java/org/pitest/coverage/CoverageReceiver.java
index d6dccd5b6..74801e7c9 100644
--- a/pitest/src/main/java/org/pitest/coverage/CoverageReceiver.java
+++ b/pitest/src/main/java/org/pitest/coverage/CoverageReceiver.java
@@ -6,8 +6,6 @@
 
 public interface CoverageReceiver extends InvokeReceiver {
 
-  void newTest();
-
   void recordTestOutcome(Description description, boolean wasGreen,
       int executionTime);
 
diff --git a/pitest/src/main/java/org/pitest/coverage/execute/CoverageDecorator.java b/pitest/src/main/java/org/pitest/coverage/execute/CoverageDecorator.java
index 5240e72e5..1c02d96ef 100644
--- a/pitest/src/main/java/org/pitest/coverage/execute/CoverageDecorator.java
+++ b/pitest/src/main/java/org/pitest/coverage/execute/CoverageDecorator.java
@@ -40,7 +40,6 @@ protected CoverageDecorator(final CoverageReceiver queue, final TestUnit child)
   @Override
   public void execute(final ResultCollector rc) {
     LOG.fine("Gathering coverage for test " + child().getDescription());
-    this.invokeQueue.newTest();
 
     final int threadsBeforeTest = this.threads.getThreadCount();
 
diff --git a/pitest/src/main/java/org/pitest/coverage/execute/CoveragePipe.java b/pitest/src/main/java/org/pitest/coverage/execute/CoveragePipe.java
index 99a911256..9efe882b1 100644
--- a/pitest/src/main/java/org/pitest/coverage/execute/CoveragePipe.java
+++ b/pitest/src/main/java/org/pitest/coverage/execute/CoveragePipe.java
@@ -20,11 +20,6 @@ public CoveragePipe(final OutputStream dos) {
     this.dos = new SafeDataOutputStream(dos);
   }
 
-  @Override
-  public synchronized void newTest() {
-    CodeCoverageStore.reset();
-  }
-
   @Override
   public synchronized void recordTestOutcome(final Description description,
       final boolean wasGreen, final int executionTime) {
@@ -38,6 +33,8 @@ public synchronized void recordTestOutcome(final Description description,
     }
     this.dos.writeBoolean(wasGreen);
     this.dos.writeInt(executionTime);
+    
+    CodeCoverageStore.reset();
 
   }