return super.read(reader);
    }

    @Override
    public Model read(InputStream in, boolean strict, InputSource source) throws IOException, XmlPullParserException {
        return super.read(in, strict, source);
    }

    @Override
    public Model read(InputStream in, boolean strict) throws IOException, XmlPullParserException {
        return super.read(in, strict);
    }

    @Override

        ttype = peekc;
        return ttype;
    }

    /**
     * Returns the string that has already been read.
     *
     * @return The string that has already been read.
     */
    public String getReadString() {
        return str.substring(0, colno - 1);
    }

    private int read() {
        if (colno >= str.length()) {
            return -1;
        }
        return str.charAt(colno++);

      int off = (int) expectedSize - remaining;
      int read = in.read(bytes, off, remaining);
      if (read == -1) {
        // end of stream before reading expectedSize bytes
        // just return the bytes read so far
        return Arrays.copyOf(bytes, off);
      }
      remaining -= read;
    }

    // bytes is now full
    int b = in.read();
    if (b == -1) {
      return bytes;
    }

     */
    public Metadata read(Reader reader) throws IOException, XmlPullParserException {
        try {
            return new Metadata(delegate.read(reader));
        } catch (XMLStreamException e) {
            throw new XmlPullParserException(e.getMessage(), null, e);
        }
    }

    /**
     * Method read.
     *
     * @param in     a in object.
     * @param strict a strict object.

     * @throws XmlPullParserException XmlPullParserException if
     *         any.
     * @see XmlStreamReader
     */
    public PersistedToolchains read(Reader reader) throws IOException, XmlPullParserException {
        return read(reader, true);
    }

    /**
     * Method read.
     *
     * @param in a in object.
     * @param strict a strict object.
     * @return PersistedToolchains

        // ## Arrange ##
        final String url = "http://example.com";

        // ## Act ##
        final CurlRequest request = Curl.head(url);

        // ## Assert ##
        assertNotNull(request);
        assertEquals(Method.HEAD, request.method());
    }

    @Test
    public void test_OptionsFactoryMethod() {
        // ## Arrange ##
        final String url = "http://example.com";

		defer deadlineconn.Close()

		// Read a line
		b := make([]byte, 12)
		_, terr = deadlineconn.Read(b)
		if terr != nil {
			t.Errorf("failed to read from client. %v", terr)
			return
		}
		received := string(b)
		if received != "message one\n" {
			t.Errorf(`server: expected: "message one\n", got: %v`, received)
			return
		}

		// Wait for more than read timeout to simulate processing.

    /**
     * Read and Write caching (RW)
     */
    public static final int SMB2_LEASE_READ_WRITE = 0x05;

    /**
     * Full caching - Read, Write and Handle (RWH)
     */
    public static final int SMB2_LEASE_FULL = 0x07;

    private Smb2LeaseState() {
        // Utility class
    }

    /**
     * Check if state has read caching
     * @param state lease state

                int read = socketChannel.read(tempBuffer);
                if (read < 0) {
                    break;
                }
                totalRead += read;
            }

            tempBuffer.flip();
            buffer.put(tempBuffer);

            log.debug("TCP RDMA read completed: {} bytes", totalRead);
            return totalRead;

        }

        try {
            mimeMap = new MimeMap();
            is = getClass().getClassLoader().getResourceAsStream("jcifs/smb1/http/ne.css");
            while ((n = is.read(buf)) != -1) {
                sb.append(new String(buf, 0, n, "ISO8859_1"));
            }
            style = sb.toString();
        } catch (final IOException ioe) {