successorsReference = new SoftReference<>(successors);
    }
    return successors;
  }

  @Override
  public Set<E> edgesConnecting(N node) {
    return new MultiEdgesConnecting<E>(outEdgeMap, node) {
      @Override
      public int size() {
        return successorsMultiset().count(node);
      }
    };
  }

  @Override

    /**
     * Gets the negotiated context flags.
     * @return context flags
     */
    int getFlags();

    /**
     * Gets the array of supported security mechanism OIDs.
     * @return array of supported mechanism OIDs
     */
    ASN1ObjectIdentifier[] getSupportedMechs();

    /**
     * Checks whether this mechanism supports message integrity.
     * @return whether this mechanisms supports integrity
     */

        this.limitSize = limitSize;
    }

    /**
     * Returns the upper limit on the number of entries.
     *
     * @return the upper limit on the number of entries
     */
    public int getLimitSize() {
        return limitSize;
    }

    @Override
    protected boolean removeEldestEntry(final Map.Entry<K, V> entry) {
        return size() > limitSize;
    }

        override fun source(): BufferedSource = uppercaseSource(delegate().source()).buffer()
      }
    return response
      .newBuilder()
      .body(uppercaseBody)
      .build()
  }

  private fun uppercaseSource(source: BufferedSource): ForwardingSource {
    return object : ForwardingSource(source) {
      @Throws(IOException::class)
      override fun read(
        sink: Buffer,

     *
     * @param responseData the data to be transformed
     * @return the transformed ResultData
     */
    ResultData transform(ResponseData responseData);

    /**
     * Retrieves data from the given AccessResultData object.
     *
     * @param accessResultData the AccessResultData object containing the data to be retrieved
     * @return an Object representing the data retrieved from the AccessResultData
     */

    return doAssertThrows(expectedThrowable, supplier, /* userPassedSupplier= */ true);
  }

  @CanIgnoreReturnValue
  static <T extends Throwable> T assertThrows(
      Class<T> expectedThrowable, ThrowingRunnable runnable) {
    return doAssertThrows(
        expectedThrowable,
        () -> {
          runnable.run();
          return null;
        },

	// Try PEM
	if block, _ := pem.Decode(priv); block != nil {
		return x509.ParsePKCS1PrivateKey(block.Bytes)
	}
	// Try base 64
	dst := make([]byte, base64.StdEncoding.DecodedLen(len(priv)))
	if n, err := base64.StdEncoding.Decode(dst, priv); err == nil {
		return x509.ParsePKCS1PrivateKey(dst[:n])
	}
	// Try Raw, return error
	return x509.ParsePKCS1PrivateKey(priv)
}

func fatalErr(err error) {
	if err == nil {

                execTime.addAndGet(100);
            }

            @Override
            public long getDocumentSize() {
                return docSize.get();
            }

            @Override
            public long getExecuteTime() {
                return execTime.get();
            }

            @Override
            public void commit() {
                // No-op for test
            }
        };

        return new Smb2CreateResponse(tc.getConfig(), this.name);
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.RequestWithPath#getPath()
     */
    @Override
    public String getPath() {
        return '\\' + this.name;
    }

    /**
     * {@inheritDoc}
     *

        }).createPageNumberList());

        return scheduledJobList;
    }

    /**
     * Gets a list of scheduled jobs that have been updated after a specific time.
     * @param updateTime The update time.
     * @return A list of scheduled jobs.
     */
    public List<ScheduledJob> getScheduledJobListAfter(final long updateTime) {
        return scheduledJobBhv.selectPage(cb -> {