@Test public void cache() throws Exception { SegmentReader<Integer> reader = readerImpl.cache(); Integer value = reader.decode(); assertEquals(new Integer(EXPECTED), value); assertSame(value, reader.decode()); }
@Override public U decode() throws IOException, OncRpcException { return fn.apply(in.decode()); }
MappedSegmentReader implements SegmentReader<U> { @Override public U decode() throws IOException, OncRpcException { return fn.apply(in.decode()); } }
MappedSegmentReader implements SegmentReader<U> { @Override public U decode() throws IOException, OncRpcException { return fn.apply(in.decode()); }  }
MappedSegmentReader implements SegmentReader<U> { @Override public U decode() throws IOException, OncRpcException { return fn.apply(in.decode()); }  @Override U decode(); }
MappedSegmentReader implements SegmentReader<U> { @Override public U decode() throws IOException, OncRpcException { return fn.apply(in.decode()); }  @Override U decode();  }