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