streamCode: ErrorCode,
    cause: IOException?,
  ) {
    assertLockNotHeld()

    ignoreIoExceptions {
      shutdown(connectionCode)
    }

    var streamsToClose: Array<Http2Stream>? = null
    withLock {
      if (streams.isNotEmpty()) {
        streamsToClose = streams.values.toTypedArray()
        streams.clear()
      }
    }

    streamsToClose?.forEach { stream ->

 *
 * @author Dimitris Andreou
 * @since 11.0
 */
@Beta
public final class Funnels {
  private Funnels() {}

  /** Returns a funnel that extracts the bytes from a {@code byte} array. */
  public static Funnel<byte[]> byteArrayFunnel() {
    return ByteArrayFunnel.INSTANCE;
  }

  private enum ByteArrayFunnel implements Funnel<byte[]> {
    INSTANCE;

    @Override

            System.clearProperty(Constants.FESS_CONFIG_PREFIX + falseKey);
        }
    }

    // Test getting array-like configuration values
    @Test
    public void test_get_arrayValues() {
        String arrayKey = "array.values";
        String arrayValue = "value1,value2,value3";

        System.setProperty(Constants.FESS_CONFIG_PREFIX + arrayKey, arrayValue);

        try {

        // Decode output parameters for WitnessAsyncNotify

        // Response buffer size
        int responseLength = buf.dec_ndr_long();

        if (responseLength > 0) {
            // Decode notification array
            int notificationCount = buf.dec_ndr_long();
            notifications = new ArrayList<>(notificationCount);

            for (int i = 0; i < notificationCount; i++) {

    /**
     * Create SMB Direct Negotiate Request
     */
    public SmbDirectNegotiateRequest() {
    }

    /**
     * Encode to byte array
     *
     * @return encoded message
     */
    public byte[] encode() {
        byte[] data = new byte[32];

        int idx = 0;
        SMBUtil.writeInt2(minVersion, data, idx);
        idx += 2;

                                            "title": "Response Response Model List Of Model No Annotation Response Model List Of Model No Annotation Get",
                                            "type": "array",
                                            "items": {
                                                "$ref": "#/components/schemas/User"
                                            },

        assertEquals(trustInfo.sid.sub_authority_count, decodedInfo.sid.sub_authority_count);
    }

    @Test
    void testLsarSidArrayEncodeDecodeRoundTrip() throws NdrException {
        // Create SID array with test data
        lsarpc.LsarSidArray sidArray = new lsarpc.LsarSidArray();
        sidArray.num_sids = 2;
        sidArray.sids = new lsarpc.LsarSidPtr[2];

        sidArray.sids[0] = new lsarpc.LsarSidPtr();

    /** The protocol the server selected. */
    var selected: String? = null

    @Throws(Throwable::class)
    override fun invoke(
      proxy: Any,
      method: Method,
      args: Array<Any>?,
    ): Any? {
      val callArgs = args ?: arrayOf<Any?>()
      val methodName = method.name
      val returnType = method.returnType

   */
  @get:JvmName("subtype") val subtype: String,
  /** Alternating parameter names with their values, like `["charset", "utf-8"]`. */
  private val parameterNamesAndValues: Array<String>,
) {
  /**
   * Returns the charset of this media type, or [defaultValue] if either this media type doesn't
   * specify a charset, or if its charset is unsupported by the current runtime.
   */
  @JvmOverloads

    T[] result = newArray(arrayOfType, to - from);
    System.arraycopy(source, from, result, 0, to - from);
    return result;
  }

  // TODO(user): Move this logic to a utility class.
  @JsType(isNative = true, name = "Array", namespace = JsPackage.GLOBAL)
  private interface NativeArray {
    @JsProperty
    void setLength(int length);
  }

  static MapMaker tryWeakKeys(MapMaker mapMaker) {
    return mapMaker;
  }