*/
    int FILE_ACTION_RENAMED_NEW_NAME = 0x00000005;

    /**
     * File stream has been added
     */
    int FILE_ACTION_ADDED_STREAM = 0x00000006;
    /**
     * File stream has been removed
     */
    int FILE_ACTION_REMOVED_STREAM = 0x00000007;
    /**
     * File stream has modified
     */
    int FILE_ACTION_MODIFIED_STREAM = 0x00000008;

    /**

            final String commandStr = stream(commands).get(stream -> stream.map(s -> {
                if ("$PASSWORD".equals(s)) {
                    return "***MASKED***";
                }
                if ("$USERNAME".equals(s)) {
                    return username;
                }
                return s;
            }).collect(java.util.stream.Collectors.joining(" ")));

    }
  }

  /**
   * Returns a stream over the values in this array, in order.
   *
   * @since 33.4.0 (but since 22.0 in the JRE flavor)
   */
  // If users use this when they shouldn't, we hope that NewApi will catch subsequent stream calls
  @IgnoreJRERequirement
  public DoubleStream stream() {
    return Arrays.stream(array, start, end);
  }

    }
  }

  /**
   * Returns a stream over the values in this array, in order.
   *
   * @since 33.4.0 (but since 22.0 in the JRE flavor)
   */
  // If users use this when they shouldn't, we hope that NewApi will catch subsequent stream calls
  @IgnoreJRERequirement
  public IntStream stream() {
    return Arrays.stream(array, start, end);
  }

    frame.writeByte(Http2.TYPE_HEADERS)
    frame.writeByte(FLAG_END_HEADERS or FLAG_PRIORITY)
    frame.writeInt(expectedStreamId and 0x7fffffff)
    frame.writeInt(0) // Independent stream.
    frame.writeByte(255) // Heaviest weight, zero-indexed.
    frame.writeAll(headerBytes)
    reader.nextFrame(
      requireSettings = false,
      object : BaseTestHandler() {
        override fun priority(

    private final CIFSContext transportContext;

    /**
     * Sets the URL stream handler factory for the environment. This
     * allows specification of the factory used in creating underlying
     * stream handlers. This can be called once per JVM instance.
     *
     * @param factory
     *            The URL stream handler factory.
     */

    @Nullable
    Path userHome();

    /**
     * Returns the input stream to be used for the Maven execution.
     * If not set, {@link System#in} will be used by default.
     *
     * @return the input stream, or null if not set
     */
    @Nullable
    InputStream stdIn();

    /**
     * Returns the output stream to be used for the Maven execution.

                }
                stream(accessToken.getPermissions()).of(stream -> stream.forEach(permissionSet::add));
                final String name = accessToken.getParameterName();
                stream(request.getParameterValues(name)).of(stream -> stream.filter(StringUtil::isNotBlank).forEach(permissionSet::add));
                return OptionalEntity.of(permissionSet);

            return true;
        }
        return stream(values).get(stream -> stream.allMatch(StringUtil::isBlank));
    }

    /**
     * Simplifies the array.
     *
     * @param values The array.
     * @return The simplified array.
     */
    protected static String[] simplifyArray(final String[] values) {

 * limitations under the License.
 */
package okhttp3.internal.http2

import java.io.IOException

/** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */
class StreamResetException(
  @JvmField val errorCode: ErrorCode,