()
| 752 | super(pout); |
| 753 | } |
| 754 | public synchronized int read() throws IOException { |
| 755 | if ( closed ) |
| 756 | throw new IOException("stream closed"); |
| 757 | |
| 758 | while (super.in < 0) { // While no data */ |
| 759 | notifyAll(); // Notify any writers to wake up |
| 760 | try { |
| 761 | wait(750); |
| 762 | } catch ( InterruptedException e ) { |
| 763 | throw new InterruptedIOException(); |
| 764 | } |
| 765 | } |
| 766 | // This is what the superclass does. |
| 767 | int ret = buffer[super.out++] & 0xFF; |
| 768 | if (super.out >= buffer.length) |
| 769 | super.out = 0; |
| 770 | if (super.in == super.out) |
| 771 | super.in = -1; /* now empty */ |
| 772 | return ret; |
| 773 | } |
| 774 | public void close() throws IOException { |
| 775 | closed = true; |
| 776 | super.close(); |
no outgoing calls
no test coverage detected