import java.io.InputStream;
import net.i2p.data.RouterIdentity;
import net.i2p.router.RouterContext;
public class BandwidthLimitedInputStream extends FilterInputStream {
private RouterIdentity _peer;
<BUG>private RouterContext _context;
public BandwidthLimitedInputStream(RouterContext context, InputStream source, RouterIdentity peer) {
super(source);</BUG>
_context = context;
<BUG>_peer = peer;
}
public int read() throws IOException {
_context.bandwidthLimiter().delayInbound(_peer, 1);</BUG>
return in.read();

import java.io.InputStream;
import net.i2p.data.RouterIdentity;
import net.i2p.router.RouterContext;
public class BandwidthLimitedInputStream extends FilterInputStream {
private RouterIdentity _peer;
private RouterContext _context;
private boolean _pullFromOutbound;
public BandwidthLimitedInputStream(RouterContext context, InputStream source, RouterIdentity peer) {
this(context, source, peer, false);
