throw sendException;
            }
        }

        @Override
        protected void doRecv(Response response) throws IOException {
            if (recvException != null) {
                throw recvException;
            }
        }

        @Override
        protected void doSkip(Long key) throws IOException {
        }

        @Override
        protected int getResponseTimeout(Request request) {

   * @return the result returned by the Callable
   * @throws TimeoutException if the time limit is reached
   * @throws ExecutionException if {@code callable} throws a checked exception
   * @throws UncheckedExecutionException if {@code callable} throws a {@code RuntimeException}
   * @throws ExecutionError if {@code callable} throws an {@code Error}
   * @since 22.0
   */
  @CanIgnoreReturnValue

     * @throws NdrException if encoding fails
     */
    public abstract void encode_in(NdrBuffer buf) throws NdrException;

    /**
     * Decode the output parameters from this DCERPC message.
     * @param buf the buffer to decode from
     * @throws NdrException if decoding fails
     */
    public abstract void decode_out(NdrBuffer buf) throws NdrException;

        } catch (ArtifactResolutionException e) {
            throw new UnresolvableModelException(e.getMessage(), groupId, artifactId, version, e);
        }

        Path pomFile = pomArtifact.getPath();

        return new FileModelSource(pomFile);
    }

    @Override
    public ModelSource resolveModel(final Parent parent) throws UnresolvableModelException {
        try {

    }
  }

  @Throws(IOException::class)
  fun flush() {
    withLock {
      if (closed) throw IOException("closed")
      sink.flush()
    }
  }

  @Throws(IOException::class)
  fun rstStream(
    streamId: Int,
    errorCode: ErrorCode,
  ) {
    withLock {
      if (closed) throw IOException("closed")
      require(errorCode.httpCode != -1)

   *
   * @throws UnsupportedOperationException always
   * @deprecated Unsupported operation.
   */
  @CanIgnoreReturnValue
  @Deprecated
  @Override
  @DoNotCall("Always throws UnsupportedOperationException")
  public final boolean putAll(Multimap<? extends K, ? extends V> multimap) {
    throw new UnsupportedOperationException();
  }

  /**

            }, "Rename operations should not throw exception");

            verify(mockResource).renameTo(destination);
            verify(mockResource).renameTo(destination, true);
        }

        @Test
        @DisplayName("renameTo should throw NullPointerException for null destination")
        void testRenameTo_NullDestination() throws CIFSException {
            // Given

     * @param length number of bytes to read
     * @return number of bytes read
     * @throws IOException if operation fails
     */
    public int rdmaRead(ByteBuffer buffer, long remoteAddress, int remoteKey, int length) throws IOException {
        if (!isRdmaConnected()) {
            throw new IOException("RDMA connection not available");
        }

        try {

                // If we had a non-critical destroy failure, throw it now
                if (failedToDestroy && destroyException != null) {
                    throw new DestroyFailedException("Partial destroy: " + destroyException.getMessage());
                }

            } catch (DestroyFailedException e) {
                // Re-throw DestroyFailedException as-is
                throw e;
            } catch (Exception e) {

    assertEquals(
        "computeIfAbsent(present, function) should return existing value",
        v0(),
        getMap()
            .computeIfAbsent(
                k0(),
                k -> {
                  throw new AssertionFailedError();
                }));
    expectUnchanged();
  }

  @MapFeature.Require(SUPPORTS_PUT)
  public void testComputeIfAbsent_functionReturnsNullNotInserted() {
    assertNull(