@Test public void messageReaderBuilderTest() { InputStream stream = new ByteArrayInputStream("".getBytes()); MessageReader reader = new MessageReader().initialize(stream, shardId, new ObjectMapper(), Executors.newCachedThreadPool()); Assert.assertNotNull(reader); }
MessageReader initialize(InputStream stream, String shardId, ObjectMapper objectMapper, ExecutorService executorService) { return this.initialize(new BufferedReader(new InputStreamReader(stream)), shardId, objectMapper, executorService); }
MessageReader { MessageReader initialize(InputStream stream, String shardId, ObjectMapper objectMapper, ExecutorService executorService) { return this.initialize(new BufferedReader(new InputStreamReader(stream)), shardId, objectMapper, executorService); } }
MessageReader { MessageReader initialize(InputStream stream, String shardId, ObjectMapper objectMapper, ExecutorService executorService) { return this.initialize(new BufferedReader(new InputStreamReader(stream)), shardId, objectMapper, executorService); } MessageReader(); }
MessageReader { MessageReader initialize(InputStream stream, String shardId, ObjectMapper objectMapper, ExecutorService executorService) { return this.initialize(new BufferedReader(new InputStreamReader(stream)), shardId, objectMapper, executorService); } MessageReader();  }
MessageReader { MessageReader initialize(InputStream stream, String shardId, ObjectMapper objectMapper, ExecutorService executorService) { return this.initialize(new BufferedReader(new InputStreamReader(stream)), shardId, objectMapper, executorService); } MessageReader();   }