// Read some data
        assertEquals('T', stream.read());

        // Close should be ignored
        stream.close();

        // Should still be able to read
        assertEquals('e', stream.read());
        assertEquals('s', stream.read());
        assertEquals('t', stream.read());
    }

                        } else {
                            return con.getInputStream();
                        }
                    } else if (Method.HEAD.toString().equalsIgnoreCase(con.getRequestMethod())) {
                        return new ByteArrayInputStream(new byte[0]);
                    } else {
                        if (GZIP.equals(con.getContentEncoding())) {

import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Read request message.
 *
 * This command is used to read data from a file that has been
 * previously opened with a Create request.
 *
 * @author mbechler
 */
public class Smb2ReadRequest extends ServerMessageBlock2Request<Smb2ReadResponse> implements RequestWithFileId {

    /**
     * Flag to indicate unbuffered read operation
     */

# to reference the most recent versions of the SIG Build Docker images.
name: Update RBE Configs
on:
  workflow_dispatch:

permissions:
  contents: read

jobs:
  rbe:
    name: Update RBE Configs
    runs-on: ubuntu-latest
    if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks
    steps:
    - name: Checkout code

    assertEquals(0, ticker.read());
    assertEquals(10, ticker.read());
    assertEquals(20, ticker.read());
  }

  public void testAutoIncrementStep_millis() {
    FakeTicker ticker = new FakeTicker().setAutoIncrementStep(1, MILLISECONDS);
    assertEquals(0, ticker.read());
    assertEquals(1000000, ticker.read());
    assertEquals(2000000, ticker.read());
  }

        }

        // Read from TemporaryFileInputStream
        try (TemporaryFileInputStream stream = new TemporaryFileInputStream(tempFile)) {
            assertEquals('T', stream.read());
            assertEquals('e', stream.read());
            assertEquals('s', stream.read());
            assertEquals('t', stream.read());
            assertEquals(' ', stream.read());
            assertEquals('d', stream.read());

     * any.
     * @return Model
     */
    public Model read(Reader reader) throws IOException, XmlPullParserException {
        return read(reader, true);
    } // -- Model read( Reader )

    protected Model read(InputStream is, boolean strict, InputSource source)
            throws IOException, XmlPullParserException {
        try {
            org.apache.maven.api.model.Model model =

   * Returns the total number of chars read. Does not close the stream.
   *
   * @since 20.0
   */
  @CanIgnoreReturnValue
  public static long exhaust(Readable readable) throws IOException {
    long total = 0;
    long read;
    CharBuffer buf = createBuffer();
    while ((read = readable.read(buf)) != -1) {
      total += read;
      Java8Compatibility.clear(buf);
    }
    return total;

        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

     */
    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.