Remove unused code

dbmdz · Jun 4, 2020 · 0ffc75d · 0ffc75d
1 parent b37cf6f
commit 0ffc75d
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/framework/src/test/java/com/github/dbmdz/flusswerk/framework/model/JobTest.java b/framework/src/test/java/com/github/dbmdz/flusswerk/framework/model/JobTest.java
@@ -42,10 +42,6 @@ public Collection<Message> apply(R r) {
     }
   }
 
-  private Supplier<RuntimeException> exception(String message) {
-    return () -> new RuntimeException(message);
-  }
-
   @Test
   @DisplayName("should call the reader")
   void read() {
@@ -80,8 +76,7 @@ void readTransformWriteShouldPassValues() {
     Job<TestMessage, String, String> job = new Job<>(message);
     job.read(TestMessage::getId);
     job.transform(String::toUpperCase);
-    job.write(
-        (Function<String, Collection<Message>>) id -> Collections.singleton(new TestMessage(id)));
+    job.write(id -> Collections.singleton(new TestMessage(id)));
 
     var actual = (TestMessage) unbox(job.getResult());
     assertThat(actual.getId()).isEqualTo(message.getId().toUpperCase());