- Stream old = (Stream)blocker.get(Thread.currentThread());
- try {
- blocker.put(Thread.currentThread(), this);
- flush();
- int ret = in.read(c, off, len);
- if (log != null && ret != -1) log(new String(c, off, ret));
- return ret;
- } finally { if (old == null) blocker.remove(Thread.currentThread()); else blocker.put(Thread.currentThread(), old); }
+ flush();
+ int ret = in.read(c, off, len);
+ if (log != null && ret != -1) log(new String(c, off, ret));
+ return ret;