git://git.nikiroo.be
/
nikiroo-utils.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
bugfixes
[nikiroo-utils.git]
/
src
/
be
/
nikiroo
/
utils
/
streams
/
NextableInputStream.java
diff --git
a/src/be/nikiroo/utils/streams/NextableInputStream.java
b/src/be/nikiroo/utils/streams/NextableInputStream.java
index b8c3fe8c5baf45b0c8b3adffa5cda11c53b99c79..62156e3e4285f53bb1d0e72e4be95f0f91ea3452 100644
(file)
--- a/
src/be/nikiroo/utils/streams/NextableInputStream.java
+++ b/
src/be/nikiroo/utils/streams/NextableInputStream.java
@@
-2,6
+2,8
@@
package be.nikiroo.utils.streams;
import java.io.IOException;
import java.io.InputStream;
import java.io.IOException;
import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
+import java.util.Arrays;
/**
* This {@link InputStream} can be separated into sub-streams (you can process
/**
* This {@link InputStream} can be separated into sub-streams (you can process
@@
-245,10
+247,20
@@
public class NextableInputStream extends BufferedInputStream {
}
public String DEBUG() {
}
public String DEBUG() {
+ String data = "";
+ if (stop > 0) {
+ try {
+ data = new String(Arrays.copyOfRange(buffer, 0, stop), "UTF-8");
+ } catch (UnsupportedEncodingException e) {
+ }
+ if (data.length() > 50) {
+ data = data.substring(0, 47) + "...";
+ }
+ }
String rep = String.format(
String rep = String.format(
- "Nextable %s: %d -> %d [eof: %s] [more data: %s]",
+ "Nextable %s: %d -> %d [eof: %s] [more data: %s]
: %s
",
(stopped ? "stopped" : "running"), start, stop, "" + eof, ""
(stopped ? "stopped" : "running"), start, stop, "" + eof, ""
- + hasMoreData());
+ + hasMoreData()
, data
);
return rep;
}
return rep;
}