}
    }

    /**
     * Base64でエンコードします。
     *
     * @param inData
     *            エンコードするデータ
     * @return エンコードされたデータ
     */
    public static String encode(final byte[] inData) {
        if (ArrayUtil.isEmpty(inData)) {
            return "";
        }
        final int mod = inData.length % 3;
        final int num = inData.length / 3;
        char[] outData = null;
        if (mod != 0) {

}

func getFileInfo(xlMetaBuf []byte, volume, path, versionID string, data, allParts bool) (FileInfo, error) {
	var fi FileInfo
	var err error
	var inData xlMetaInlineData
	if buf, data, e := isIndexedMetaV2(xlMetaBuf); e != nil {
		return FileInfo{}, e
	} else if buf != nil {
		inData = data
		fi, err = buf.ToFileInfo(volume, path, versionID, allParts)
		if len(buf) != 0 && errors.Is(err, errFileNotFound) {

 *
 * While [onReset] may occur at any time, the following callbacks are expected in order,
 * correlated by stream ID.
 *
 *  * [onRequest]
 *  * [onHeaders] (unless canceled)
 *  * [onData] (optional sequence of data frames)
 *
 * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple
 * connections should expect repetition of stream IDs.
 *

            "new-subscription": {
                "post": {
                    "summary": "New Subscription",
                    "description": "When a new user subscribes to your service we'll send you a POST request with this\ndata to the URL that you register for the event `new-subscription` in the dashboard.",
                    "operationId": "new_subscriptionnew_subscription_post",
                    "requestBody": {
                        "content": {

            "new-subscription": {
                "post": {
                    "summary": "New Subscription",
                    "description": "When a new user subscribes to your service we'll send you a POST request with this\ndata to the URL that you register for the event `new-subscription` in the dashboard.",
                    "operationId": "new_subscriptionnew_subscription_post",
                    "requestBody": {
                        "content": {

    source.require(byteCount.toLong()) // Eagerly read the frame before firing client thread.
    source.read(buffer, byteCount.toLong())
    pushQueue.execute("$connectionName[$streamId] onData") {
      ignoreIoExceptions {
        val cancel = pushObserver.onData(streamId, buffer, byteCount, inFinished)
        if (cancel) writer.rstStream(streamId, ErrorCode.CANCEL)
        if (cancel || inFinished) {
          synchronized(this@Http2Connection) {

      events.add(responseHeaders)
      notifyAll()
      return false
    }

    @Synchronized override fun onData(
      streamId: Int,
      source: BufferedSource,
      byteCount: Int,
      last: Boolean,
    ): Boolean {
      events.add(AssertionError("onData"))
      notifyAll()
      return false
    }

    @Synchronized override fun onReset(
      streamId: Int,

EAAMumB,IA5a/BllB,EAAO2lB,MAAQ,CAEdnpB,OAAQ,GAERmc,IAAK,SAAUtX,EAAMmkB,EAAO1Z,EAAS8T,EAAM3f,GAE1C,IAAIsmB,EAAaC,EAAa1Y,EAC7B2Y,EAAQC,EAAGC,EACXrK,EAASsK,EAAUjoB,EAAMkoB,EAAYC,EACrCC,EAAWhH,EAASpf,IAAKU,GAG1B,GAAMge,EAAYhe,GAAlB,CAKKyK,EAAQA,UAEZA,GADAya,EAAcza,GACQA,QACtB7L,EAAWsmB,EAAYtmB,UAKnBA,GACJD,EAAO2N,KAAKM,gBAAiBnB,GAAiB7M,GAIzC6L,EAAQ1H,OACb0H,EAAQ1H,KAAOpE,EAAOoE,SAIfqiB,EAASM,EAASN,UACzBA,EAASM,EAASN,OAASrpB,OAAO4pB,OAAQ,QAEnCR,EAAcO,EAASE,UAC9BT,EAAcO,EAASE,OAAS,SAAUxd,GAIzC,MAAyB,o...

EAAMumB,IA5a/BllB,EAAO2lB,MAAQ,CAEdnpB,OAAQ,GAERmc,IAAK,SAAUtX,EAAMmkB,EAAO1Z,EAAS8T,EAAM3f,GAE1C,IAAIsmB,EAAaC,EAAa1Y,EAC7B2Y,EAAQC,EAAGC,EACXrK,EAASsK,EAAUjoB,EAAMkoB,EAAYC,EACrCC,EAAWhH,EAASpf,IAAKU,GAG1B,GAAMge,EAAYhe,GAAlB,CAKKyK,EAAQA,UAEZA,GADAya,EAAcza,GACQA,QACtB7L,EAAWsmB,EAAYtmB,UAKnBA,GACJD,EAAO2N,KAAKM,gBAAiBnB,GAAiB7M,GAIzC6L,EAAQ1H,OACb0H,EAAQ1H,KAAOpE,EAAOoE,SAIfqiB,EAASM,EAASN,UACzBA,EAASM,EAASN,OAASrpB,OAAO4pB,OAAQ,QAEnCR,EAAcO,EAASE,UAC9BT,EAAcO,EAASE,OAAS,SAAUxd,GAIzC,MAAyB,o...