From a388acfce4e39e2e5d6a7a4b459b3767c46e7ff8 Mon Sep 17 00:00:00 2001
From: Sebastian Stenzel <sebastian.stenzel@gmail.com>
Date: Fri, 1 Jan 2016 12:50:25 +0100
Subject: [PATCH] added test

---
 .../engine/impl/FifoParallelDataProcessorTest.java  | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/main/filesystem-crypto/src/test/java/org/cryptomator/crypto/engine/impl/FifoParallelDataProcessorTest.java b/main/filesystem-crypto/src/test/java/org/cryptomator/crypto/engine/impl/FifoParallelDataProcessorTest.java
index 99d94c77a..418c4155c 100644
--- a/main/filesystem-crypto/src/test/java/org/cryptomator/crypto/engine/impl/FifoParallelDataProcessorTest.java
+++ b/main/filesystem-crypto/src/test/java/org/cryptomator/crypto/engine/impl/FifoParallelDataProcessorTest.java
@@ -16,6 +16,19 @@ import org.junit.Test;
 
 public class FifoParallelDataProcessorTest {
 
+	@Test(expected = IllegalStateException.class)
+	public void testRethrowsException() throws InterruptedException {
+		FifoParallelDataProcessor<Object> processor = new FifoParallelDataProcessor<>(1, 1);
+		try {
+			processor.submit(() -> {
+				throw new IllegalStateException("will be rethrown during 'processedData()'");
+			});
+		} catch (Exception e) {
+			Assert.fail("Exception must not yet be thrown.");
+		}
+		processor.processedData();
+	}
+
 	@Test
 	public void testStrictFifoOrder() throws InterruptedException {
 		FifoParallelDataProcessor<Integer> processor = new FifoParallelDataProcessor<>(4, 10);