1 files changed, 13 insertions, 0 deletions
diff --git a/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/signal/ArrayRequest.java b/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/signal/ArrayRequest.java
index 8b357567e8..ca5e366542 100644
--- a/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/signal/ArrayRequest.java
+++ b/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/signal/ArrayRequest.java
@@ -22,16 +22,29 @@ public class ArrayRequest extends RequestWithConfirmation<byte[]>
 {
   private byte[] data;
 
+  private boolean flush;
+
   public ArrayRequest(SignalProtocol<?> protocol, byte[] data)
   {
+    this(protocol, data, false);
+  }
+
+  public ArrayRequest(SignalProtocol<?> protocol, byte[] data, boolean flush)
+  {
     super(protocol, TestSignalProtocol.SIGNAL_ARRAY);
     this.data = data;
+    this.flush = flush;
   }
 
   @Override
   protected void requesting(ExtendedDataOutputStream out) throws Exception
   {
     out.writeByteArray(data);
+
+    if (flush)
+    {
+      out.flush();
+    }
   }
 
   @Override