Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 926 for Executed (0.06 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java

        //
    
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public HtmlResponse index() {
            saveToken();
            return asHtml(path_AdminGeneral_AdminGeneralJsp).useForm(EditForm.class, setup -> {
                setup.setup(form -> {
                    updateForm(fessConfig, form);
                });
            });
        }
    
        @Execute
        @Secured({ ROLE })
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  2. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt

            ).setHeader("content-type", "text/event-stream")
            .build(),
        )
        val request =
          Request.Builder()
            .url(server.url("/"))
            .build()
        val response = client.newCall(request).execute()
        processResponse(response, listener)
        listener.assertOpen()
        listener.assertEvent(null, null, "hey")
        listener.assertClose()
      }
    
      @Test
      fun cancelShortCircuits() {
        server.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. samples/simple-client/src/main/java/okhttp3/sample/OkHttpContributors.java

        // Create request for remote resource.
        Request request = new Request.Builder()
            .url(ENDPOINT)
            .build();
    
        // Execute the request and retrieve the response.
        try (Response response = client.newCall(request).execute()) {
          // Deserialize HTTP response to concrete type.
          ResponseBody body = response.body();
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. istioctl/cmd/root_test.go

    	_ = parent.PersistentFlags().String(childFlag2, "", childFlag2)
    	parent.AddCommand(child)
    
    	// verify both parent flags and the child flag are visible by default
    	parent.SetArgs([]string{"child", "--help"})
    	if err := parent.Execute(); err != nil {
    		t.Fatal(err)
    	}
    	got := out.String()
    	out.Reset()
    	checkHelpForFlag(t, got, parentFlag0, true)
    	checkHelpForFlag(t, got, parentFlag1, true)
    	checkHelpForFlag(t, got, parentFlag2, true)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 15 17:59:55 UTC 2021
    - 2.4K bytes
    - Viewed (0)
  5. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
     * complete}. If the computation has already completed when the listener is added, the listener will
     * execute immediately.
     *
     * <p>See the Guava User Guide article on <a
     * href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code
     * ListenableFuture}</a>.
     *
     * <p>This class is GWT-compatible.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
     * complete}. If the computation has already completed when the listener is added, the listener will
     * execute immediately.
     *
     * <p>See the Guava User Guide article on <a
     * href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code
     * ListenableFuture}</a>.
     *
     * <p>This class is GWT-compatible.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  7. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                        return builder.execute();
                    });
                    if (bulkResponse.hasFailures()) {
                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/CacheResponse.java

        Request request = new Request.Builder()
            .url("http://publicobject.com/helloworld.txt")
            .build();
    
        String response1Body;
        try (Response response1 = client.newCall(request).execute()) {
          if (!response1.isSuccessful()) throw new IOException("Unexpected code " + response1);
    
          response1Body = response1.body().string();
          System.out.println("Response 1 response:          " + response1);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun May 22 01:29:42 UTC 2016
    - 2.4K bytes
    - Viewed (0)
  9. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/lifecycle/Execution.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.plugin.lifecycle;
    
    /**
     * A set of goals to execute.
     *
     * @version $Revision$ $Date$
     */
    @SuppressWarnings("all")
    public class Execution implements java.io.Serializable {
    
        // --------------------------/
        // - Class/Member Variables -/
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/internal/TriggerSink.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     *
     */
    package mockwebserver3.internal
    
    import okio.Buffer
    import okio.Sink
    
    /**
     * A sink that executes [trigger] after [triggerByteCount] bytes are written, and then skips all
     * subsequent bytes.
     */
    internal class TriggerSink(
      private val delegate: Sink,
      private val triggerByteCount: Long,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.4K bytes
    - Viewed (0)
Back to top