assertThat(inflater.inflate(message)).isEqualTo("22021002".decodeHex())
  }

  @Test fun `deflate golden value`() {
    val deflater = MessageDeflater(false)
    val deflated = deflater.deflate("Hello deflate!".encodeUtf8())
    assertThat(deflated.hex()).isEqualTo("f248cdc9c95748494dcb492c49550400")
  }

  @Test fun `inflate deflate`() {
    val deflater = MessageDeflater(false)
    val inflater = MessageInflater(false)

		Method: Deflate,
		Mode:   0644,
	},
	{
		Name:   "setuid",
		Data:   []byte("setuid file"),
		Method: Deflate,
		Mode:   0755 | fs.ModeSetuid,
	},
	{
		Name:   "setgid",
		Data:   []byte("setgid file"),
		Method: Deflate,
		Mode:   0755 | fs.ModeSetgid,
	},
	{
		Name:   "symlink",
		Data:   []byte("../link/target"),
		Method: Deflate,
		Mode:   0755 | fs.ModeSymlink,
	},

 * Sec-WebSocket-Extensions: permessage-deflate; client_no_context_takeover
 * Sec-WebSocket-Extensions: permessage-deflate; server_max_window_bits="15"
 * Sec-WebSocket-Extensions: permessage-deflate; server_max_window_bits=15
 * Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover
 * Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover;
 *     client_no_context_takeover

}

func ExampleWriter_RegisterCompressor() {
	// Override the default Deflate compressor with a higher compression level.

	// Create a buffer to write our archive to.
	buf := new(bytes.Buffer)

	// Create a new zip archive.
	w := zip.NewWriter(buf)

	// Register a custom Deflate compressor.
	w.RegisterCompressor(zip.Deflate, func(out io.Writer) (io.WriteCloser, error) {

    successfulExtensions("permessage-deflate")
  }

  @Test
  @Throws(Exception::class)
  fun compressedMessagesNoClientContextTakeover() {
    successfulExtensions("permessage-deflate; client_no_context_takeover")
  }

  @Test
  @Throws(Exception::class)
  fun compressedMessagesNoServerContextTakeover() {
    successfulExtensions("permessage-deflate; server_no_context_takeover")
  }

	compressors.Store(Deflate, Compressor(func(w io.Writer) (io.WriteCloser, error) { return newFlateWriter(w), nil }))

	decompressors.Store(Store, Decompressor(io.NopCloser))
	decompressors.Store(Deflate, Decompressor(newFlateReader))
}

// RegisterDecompressor allows custom decompressors for a specified method ID.
// The common methods [Store] and [Deflate] are built in.

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.cbean.ca;

import org.codelibs.fess.opensearch.config.cbean.ca.bs.BsRelatedQueryCA;

/**
 * @author ESFlute (using FreeGen)
 */
public class RelatedQueryCA extends BsRelatedQueryCA {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.cbean.ca;

import org.codelibs.fess.opensearch.config.cbean.ca.bs.BsScheduledJobCA;

/**
 * @author ESFlute (using FreeGen)
 */
public class ScheduledJobCA extends BsScheduledJobCA {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.cbean.cq;

import org.codelibs.fess.opensearch.config.cbean.cq.bs.BsBadWordCQ;

/**
 * @author ESFlute (using FreeGen)
 */
public class BadWordCQ extends BsBadWordCQ {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.cbean.cq;

import org.codelibs.fess.opensearch.config.cbean.cq.bs.BsDuplicateHostCQ;

/**
 * @author ESFlute (using FreeGen)
 */
public class DuplicateHostCQ extends BsDuplicateHostCQ {