Remove code duplications

Author: akarnokd

tck/src/main/java/org/reactivestreams/tck/IdentityProcessorVerification.java

@@ -457,8 +457,6 @@ public TestSetup apply(Long aLong) throws Throwable {
 
             sub1.request(1);
             sub2.request(1);
-
-            sendError(ex);
           } else {
             sub1.request(1);
             expectRequest();
@@ -468,9 +466,9 @@ public TestSetup apply(Long aLong) throws Throwable {
 
             // sub1 has received one element, and has one demand pending
             // sub2 has not yet requested anything
-
-            sendError(ex);
           }
+          sendError(ex);
+
           sub1.expectError(ex);
           sub2.expectError(ex);
 
@@ -744,21 +742,16 @@ public TestSetup apply(Long subscribers) throws Throwable {
             final T z = sendNextTFromUpstream();
             expectNextElement(sub1, z);
             expectNextElement(sub2, z);
-
-            if (totalRequests == 3) {
-              expectRequest();
-            }
           } else {
             final T z = sendNextTFromUpstream();
             expectNextElement(sub1, z);
             sub2.expectNone(); // since sub2 hasn't requested anything yet
 
             sub2.request(1);
             expectNextElement(sub2, z);
-
-            if (totalRequests == 3) {
-              expectRequest();
-            }
+          }
+          if (totalRequests == 3) {
+            expectRequest();
           }
 
           // to avoid error messages during test harness shutdown