| 1543 | |
| 1544 | |
| 1545 | class SavedRequestStreamInputBuffer extends StreamInputBuffer { |
| 1546 | |
| 1547 | private final SavedRequestInputFilter inputFilter; |
| 1548 | |
| 1549 | SavedRequestStreamInputBuffer(SavedRequestInputFilter inputFilter) { |
| 1550 | this.inputFilter = inputFilter; |
| 1551 | } |
| 1552 | |
| 1553 | |
| 1554 | @Override |
| 1555 | public int doRead(ApplicationBufferHandler handler) throws IOException { |
| 1556 | return inputFilter.doRead(handler); |
| 1557 | } |
| 1558 | |
| 1559 | @Override |
| 1560 | public int available() { |
| 1561 | return inputFilter.available(); |
| 1562 | } |
| 1563 | |
| 1564 | @Override |
| 1565 | void receiveReset() { |
| 1566 | // NO-OP |
| 1567 | } |
| 1568 | |
| 1569 | @Override |
| 1570 | void swallowUnread() throws IOException { |
| 1571 | // NO-OP |
| 1572 | } |
| 1573 | |
| 1574 | @Override |
| 1575 | void notifyEof() { |
| 1576 | // NO-OP |
| 1577 | } |
| 1578 | |
| 1579 | @Override |
| 1580 | ByteBuffer getInBuffer(boolean create) { |
| 1581 | return null; |
| 1582 | } |
| 1583 | |
| 1584 | @Override |
| 1585 | void onDataAvailable() throws IOException { |
| 1586 | // NO-OP |
| 1587 | } |
| 1588 | |
| 1589 | @Override |
| 1590 | boolean isReadyForRead() { |
| 1591 | return true; |
| 1592 | } |
| 1593 | |
| 1594 | @Override |
| 1595 | boolean isRequestBodyFullyRead() { |
| 1596 | return inputFilter.isFinished(); |
| 1597 | } |
| 1598 | |
| 1599 | @Override |
| 1600 | void insertReplayedBody(ByteChunk body) { |
| 1601 | // NO-OP |
| 1602 | } |
nothing calls this directly
no outgoing calls
no test coverage detected