File	Doc	Category	Size	Date	Package
SchedulerNotifyInputStream.java	API Doc	Apache James 2.3.1	4061	Fri Jan 12 12:56:34 GMT 2007	org.apache.james.util

SchedulerNotifyInputStream

• java.lang.Object
  • java.io.InputStream

Fields Summary
InputStream	in The wrapped InputStream
org.apache.avalon.cornerstone.services.scheduler.TimeScheduler	scheduler The scheduler managing the trigger to be reset by this stream
String	triggerName The name of the trigger
int	lengthReset The number of bytes that need to be read before the counter is reset.
int	readCounter The number of bytes read since the counter was last reset

Constructors Summary

public SchedulerNotifyInputStream(InputStream in, org.apache.avalon.cornerstone.services.scheduler.TimeScheduler scheduler, String triggerName, int lengthReset) param in the InputStream to be wrapped by this stream param scheduler the TimeScheduler managing the trigger to be reset by this stream param triggerName the name of the particular trigger to be reset by this stream param lengthReset the number of bytes to be read in between trigger resets this.in = in; this.scheduler = scheduler; this.triggerName = triggerName; this.lengthReset = lengthReset; readCounter = 0;

Methods Summary
public void	close() Close the stream throws IOException if an exception is encountered when closing in.close();
public int	read(byte[] b, int off, int len) Read an array of bytes from the stream param b the array of bytes to read from the stream param off the index in the array where we start writing param len the number of bytes of the array to read return the number of bytes read throws IOException if an exception is encountered when reading int l = in.read(b, off, len); readCounter += l; if (readCounter > lengthReset) { readCounter -= lengthReset; scheduler.resetTrigger(triggerName); } return l;
public int	read() Read a byte from the stream return the byte read from the stream throws IOException if an exception is encountered when reading int b = in.read(); readCounter++; if (readCounter > lengthReset) { readCounter -= lengthReset; scheduler.resetTrigger(triggerName); } return b;