- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for GetResponse (0.23 sec)
-
src/test/java/org/codelibs/fess/suggest/SuggesterTest.java
assertEquals(1, response.getNum()); assertEquals("全文 検索", response.getWords().get(0)); response = suggester.suggest().addKind("query").execute().getResponse(); assertEquals(1, response.getNum()); SuggestResponse response2 = suggester.suggest().setSuggestDetail(true).execute().getResponse(); assertEquals(2, response2.getNum());
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 37K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriter.java
return new SuggestWriterResult(); } for (final SuggestItem item : mergedItems) { final GetResponse getResponse = client.prepareGet().setIndex(index).setId(item.getId()).get(TimeValue.timeValueSeconds(30)); if (update && getResponse.isExists()) { final IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE, index);
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
server.enqueue(response) assertContent("ABCDEFGHIJKLMNOPQR", getResponse(newRequest("/foo"))) assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) assertContent("ABCDEFGHIJKLMNOPQR", getResponse(newRequest("/bar?baz=quux"))) assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) assertContent("ABCDEFGHIJKLMNOPQR", getResponse(newRequest("/z"))) assertThat(server.takeRequest().sequenceNumber).isEqualTo(2)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/SuggestSettings.java
} } public Object get(final String key) { final GetResponse getResponse = client.prepareGet().setIndex(settingsIndexName).setId(settingsId).execute().actionGet(getSearchTimeout()); if (!getResponse.isExists()) { return null; } final Map<String, Object> map = getResponse.getSource(); return map.get(key); }
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 11.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComClose.java
this.lastWriteTime = lastWriteTime; } /** * {@inheritDoc} * * @see jcifs.internal.smb1.ServerMessageBlock#getResponse() */ @Override public final SmbComBlankResponse getResponse () { return (SmbComBlankResponse) super.getResponse(); } /** * {@inheritDoc} * * @see jcifs.internal.Request#initResponse(jcifs.CIFSContext) */
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 3.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */ public void assertPriorCallReturns(boolean expected, @Nullable String methodName) throws Exception { assertEquals(expected, getResponse(methodName).getResult()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
README.md
```java String suggestId = "id"; Suggester suggester = Suggester.builder().build(client, suggestId); ``` ### Suggest ```java SuggestResponse response = suggester.suggest().setQuery("kensaku").execute().getResponse(); ``` ### Suggest async ``` suggester.suggest().setQuery("kensaku").execute() .done( response -> {} ).error( t -> {} ); ``` ### Add suggest document ```java
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Jan 19 03:33:49 UTC 2023 - 1.4K bytes - Viewed (0) -
test-site/app/models/SuggestIndex.java
public class SuggestIndex { public SuggestResponse suggest(String query) { return ComponentsUtil.suggester.suggest() .setQuery(query) .execute().getResponse(); } public void index() { Suggester suggester = ComponentsUtil.suggester; DocumentReader reader = new ESSourceReader(ComponentsUtil.runner.client(), suggester.settings(),
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Fri Nov 06 08:48:32 UTC 2015 - 964 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */ public void assertPriorCallReturns(boolean expected, @Nullable String methodName) throws Exception { assertEquals(expected, getResponse(methodName).getResult()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null)); }); th.start(); SuggestResponse response = deferred.promise().getResponse(10, TimeUnit.SECONDS); assertEquals(0, response.getNum()); } @Test public void test_getResponseAfterResolve() throws Exception {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.8K bytes - Viewed (0)