Author: janb
Date: Tue Jul 29 03:45:51 2008
New Revision: 680666
URL: http://svn.apache.org/viewvc?rev=680666&view=rev
Log:
Method signature on read was wrong.
Modified:
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/spi/http/client/ObservableInputStream.java
Modified:
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/spi/http/client/ObservableInputStream.java
URL:
http://svn.apache.org/viewvc/maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/spi/http/client/ObservableInputStream.java?rev=680666&r1=680665&r2=680666&view=diff
==============================================================================
---
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/spi/http/client/ObservableInputStream.java
(original)
+++
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/spi/http/client/ObservableInputStream.java
Tue Jul 29 03:45:51 2008
@@ -34,7 +34,7 @@
{
Set<StreamObserver> observers = new HashSet<StreamObserver>();
- protected ObservableInputStream(InputStream in)
+ public ObservableInputStream(InputStream in)
{
super(in);
}
@@ -42,21 +42,24 @@
public int read(byte[] b, int off, int len) throws IOException
{
int result = in.read(b, off, len);
- if (result != -1) {
+ if (result != -1)
+ {
notifyListeners(b, off, result);
}
return result;
}
- public int read(byte[] b) throws IOException
+ public int read() throws IOException
{
int ch = in.read();
- if (ch != -1) {
+ if (ch != -1)
+ {
notifyListeners(ch);
}
return ch;
}
+
public void addObserver (StreamObserver o)
{
