* limitations under the License.
 */

package com.google.common.collect;

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.Collection;
import java.util.Map;
import org.jspecify.annotations.Nullable;

/**

     * @param model The model to serialize, must not be {@code null}.
     * @throws IOException If the model could not be serialized.
     */
    void write(File output, Map<String, Object> options, Model model) throws IOException;

    /**
     * Writes the supplied model to the specified character writer. The writer will be automatically closed before the
     * method returns.

        tmp = new byte[TMP_BUFFER_SIZE];
    }

    @Override
    public synchronized int read() throws IOException {
        if (read(tmp, 0, 1) < 0) {
            return -1;
        }
        return tmp[0] & 0xFF;
    }

    @Override
    public synchronized int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    /* This method will not return until len bytes have been read

        // Arrange
        int access = 0x01;
        IOException expectedException = new IOException("Network error");
        // Simulate IOException during RPC call
        doThrow(expectedException).when(mockDcerpcHandle).sendrecv(any(MsrpcSamrOpenDomain.class));

        // Act & Assert
        IOException thrown = assertThrows(IOException.class, () -> {

        }

        try {
            while (data.hasRemaining()) {
                socketChannel.write(data);
            }
        } catch (IOException e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("TCP RDMA send failed", e);
        }
    }

    @Override
    public ByteBuffer receive(int timeout) throws IOException {

        }
      }
    }

    internal fun failRejected(e: RejectedExecutionException? = null) {
      val ioException = InterruptedIOException("executor rejected")
      ioException.initCause(e)
      noMoreExchanges(ioException)
      responseCallback.onFailure(this@RealCall, ioException)
    }

    override fun run() {
      threadName("OkHttp ${redactedUrl()}") {
        var signalledCallback = false

   *     Corresponds to `FLAG_FIN`.
   */
  @Throws(IOException::class)
  fun newStream(
    requestHeaders: List<Header>,
    out: Boolean,
  ): Http2Stream = newStream(0, requestHeaders, out)

  @Throws(IOException::class)
  private fun newStream(
    associatedStreamId: Int,
    requestHeaders: List<Header>,
    out: Boolean,

        path = pipe.unc;
    }

    @Override
    public void close() throws IOException {
        pipe.close();
    }

    @Override
    public void write(final int b) throws IOException {
        tmp[0] = (byte) b;
        write(tmp, 0, 1);
    }

    @Override
    public void write(final byte[] b) throws IOException {
        write(b, 0, b.length);
    }

    @Override

    }

    @Test
    @DisplayName("parsing malformed token throws IOException")
    void testMalformedToken() {
        byte[] bad = new byte[] { 0x01, 0x02, 0x03 }; // not a valid ASN.1 tagged object
        assertThrows(IOException.class, () -> new NegTokenTarg(bad), "Malformed byte[] should cause IOException");
    }

    @Test
    @DisplayName("mechanism token empty array – preserved after round‑trip")

     * @throws IOException if an I/O error occurs
     */
    public long readUnsignedInt() throws IOException {
        return readInt() & 0xffffffffL;
    }

    /**
     * Reads an unsigned 16-bit short value.
     * @return the unsigned short value as an integer
     * @throws IOException if an I/O error occurs
     */
    public int readUnsignedShort() throws IOException {