@Test
public void testMark() {

	int expectedReadLimit = 1;
	AtomicBoolean markCalled = new AtomicBoolean();
	UnsyncFilterInputStream unsyncFilterInputStream =
		new UnsyncFilterInputStream(
			new TestInputStream() {
				@Override
				public void mark(int readLimit) {
					Assert.assertEquals(expectedReadLimit, readLimit);
					markCalled.set(true);
				}
			});
	unsyncFilterInputStream.mark(expectedReadLimit);
	Assert.assertTrue(markCalled.get());
}