fun newClientBuilder(): OkHttpClient.Builder = newClient().newBuilder()

  @Synchronized private fun addEvent(event: String) {
    if (recordEvents) {
      logger?.info(event)

      synchronized(clientEventsList) {
        clientEventsList.add(event)
      }
    }
  }

  @Synchronized private fun initUncaughtException(throwable: Throwable) {

                    }
                }
            } catch (final IOException e) {
                throw new CrawlingAccessException("Failed to access permission info", e);
            }
            if (logger.isDebugEnabled()) {
                logger.debug("fileUrl:{} roleType:{}", responseData.getUrl(), roleTypeList);
            }
        }
        return roleTypeList;

//// tab | テスト

/// info | 情報
いくつかのテキスト
///

/// note | 備考
いくつかのテキスト
///

/// note | 技術詳細
いくつかのテキスト
///

/// check | 確認
いくつかのテキスト
///

/// tip | 豆知識
いくつかのテキスト
///

/// warning | 注意
いくつかのテキスト
///

/// danger | 警告
いくつかのテキスト
///

////

//// tab | 情報

import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;

import jcifs.smb.SID;

/**
 * Unit tests for PacLogonInfo class.
 * Tests the parsing and data extraction from PAC Logon Info structures.
 */
class PacLogonInfoTest {

    private static final long TEST_FILETIME = 130640000000000000L;
    private static final String TEST_USERNAME = "testuser";

                    this.gssContext.getMech());
        } catch (GSSException e) {
            log.debug("Failed to get info", e);
            return super.toString();
        }
    }

    @Override
    public void dispose() throws SmbException {
        if (this.gssContext != null) {
            try {

これは[JSON Lines のストリーミング](stream-json-lines.md)に似ていますが、`text/event-stream` フォーマットを使用します。これはブラウザがネイティブに [`EventSource` API](https://developer.mozilla.org/en-US/docs/Web/API/EventSource) でサポートしています。

/// info | 情報

FastAPI 0.135.0 で追加されました。

///

## Server-Sent Events とは { #what-are-server-sent-events }

SSE は、HTTP 経由でサーバーからクライアントへデータをストリーミングするための標準です。

                searchEngineClient.admin().indices().prepareClose(docIndex).execute(ActionListener.wrap(res -> {
                    logger.info("Closing index: {}", docIndex);
                    searchEngineClient.admin().indices().prepareOpen(docIndex).execute(ActionListener.wrap(res2 -> {
                        logger.info("Opened index: {}", docIndex);
                        coordinator.completeOperation("reload_doc_index");
                    }, e -> {

	filter := func() (commonCount uint64) {
		maxCnt := 0
		signatureMap := map[uint64]int{}
		for _, info := range infos {
			if info.Error != "" {
				continue
			}
			mutations := info.Metrics.TotalDeletes + info.Metrics.TotalWrites
			signatureMap[mutations]++
		}
		for ops, count := range signatureMap {
			if maxCnt < count && commonCount < ops {
				maxCnt = count

# 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active return 0 } # checkPolicyExists ($policy) # Check if the policy exists, by using the exit code of `mc admin policy info` checkPolicyExists() { POLICY=$1 CMD=$(${MC} admin policy info myminio $POLICY > /dev/null 2>&1) return $? } # createPolicy($name, $filename) createPolicy () { NAME=$1 FILENAME=$2 # Create the name if it does not exist echo "Checking policy: $NAME (in /config/$FILENAME.json)" if...

        List<FileNotifyInformation> notifications = response.getNotifyInformation();
        assertEquals(1, notifications.size());

        FileNotifyInformation info = notifications.get(0);
        assertEquals(1, info.getAction());
        assertEquals("test.txt", info.getFileName());
    }

    @Test
    @DisplayName("Should read multiple notifications from wire format")
    void testReadMultipleNotifications() throws Exception {