You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@maven.apache.org by ja...@apache.org on 2008/07/29 12:45:52 UTC
svn commit: r680666 -
/maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/spi/http/client/ObservableInputStream.java
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)
{