X-Git-Url: http://git.megacz.com/?p=org.ibex.io.git;a=blobdiff_plain;f=src%2Forg%2Fibex%2Fio%2FStream.java;fp=src%2Forg%2Fibex%2Fio%2FStream.java;h=70c90f832fd01a3d8bdf2dd9715f53e5d6b5151e;hp=2cc2e1486abdad1354fc263f4a80de0e0cbeec8d;hb=f658e02ec5209c9669351800503f448d38c16bbb;hpb=40b2691b0b6222e684d81d846d7ec42fcab5621b diff --git a/src/org/ibex/io/Stream.java b/src/org/ibex/io/Stream.java index 2cc2e14..70c90f8 100644 --- a/src/org/ibex/io/Stream.java +++ b/src/org/ibex/io/Stream.java @@ -43,6 +43,7 @@ public class Stream { // Main API ////////////////////////////////////////////////////////////////////////////// + public void setLimit(int limit) { in.setLimit(limit); } public char peekc() { flush(); return in.getc(true); } public char getc() { flush(); return in.getc(false); } public String readln() { flush(); return in.readln(); } @@ -52,6 +53,7 @@ public class Stream { public void writeBytes(byte[] b, int off, int len) { try { out.write(b, off, len); } catch (IOException e) { ioe(e); } } public int read(byte[] b, int off, int len) { flush(); return in.readBytes(b, off, len); } public int read(char[] c, int off, int len) { flush(); return in.readChars(c, off, len); } + public int skip(int len) { return in.skip(len); } public void close() { try { if (in!=null) in.close(); } finally { if (out!=null) out.close(); } } public void setNewline(String s) { newLine = s; } public InputStream getInputStream() { return in; } @@ -85,12 +87,14 @@ public class Stream { public char getc(boolean peek) { return cbr.getc(peek); } public String readln() { return cbr.readln(); } + public int skip(int len) { return bbis.skip(len); } public int read() { return bbis.read(); } public int read(byte[] b) { try { return bbis.read(b); } catch (IOException e) { ioe(e); return 0; } } public int read(byte[] b, int off, int len) { return bbis.read(b, off, len); } public void close() { try { cbr.close(); } catch (Exception e) { Log.error(this, e); } } public int readBytes(byte[] b, int off, int len) { return bbis.read(b, off, len); } public int readChars(char[] c, int off, int len) { return cbr.read(c, off, len); } + public void setLimit(int len) { bbis.setLimit(len); } public In(InputStream in) { bbis = new ByteBufInputStream(in) {