01: package java.io;
02:
03: public class PipedInputStream extends InputStream {
04: PipedOutputStream source;
05: boolean closed;
06: protected static final int PIPE_SIZE = 1024;
07: protected byte[] buffer = new byte[PIPE_SIZE];
08: protected int in = -1;
09: protected int out = 0;
10:
11: public PipedInputStream() {
12: }
13:
14: public PipedInputStream(PipedOutputStream source)
15: throws IOException {
16: }
17:
18: public void connect(PipedOutputStream source) throws IOException {
19: }
20:
21: protected synchronized void receive(int b) throws IOException {
22: }
23:
24: synchronized void receive(byte[] buf, int offset, int len)
25: throws IOException {
26: }
27:
28: public int read() throws IOException {
29: }
30:
31: public synchronized int read(byte[] buf, int offset, int len)
32: throws IOException {
33: }
34:
35: public synchronized int available() throws IOException {
36: }
37:
38: public synchronized void close() throws IOException {
39: }
40: }
|