@Test
    public void testBytelArrayRead() throws Exception{
        final byte[] input = new byte[10 * BYTES_PER_MB];
        final byte[] output = new byte[input.length];
        final byte[] expected = new byte[input.length];
        Arrays.fill(expected, (byte)0);
        new Random().nextBytes(input);
        final ConnectionProcessor cp = new MockConnectionProcessor();
        final Filter[] filters = new Filter[]{ new ZeroFilter(cp, new Properties())};
        new TroubleInputStream(new ByteArrayInputStream(input), filters).read(output);
        Assert.assertArrayEquals(expected, output);
    }