Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 926 for Executed (0.07 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

        Listener(Runnable command, Executor executor) {
          this.command = checkNotNull(command);
          this.executor = checkNotNull(executor);
        }
    
        void execute() {
          try {
            executor.execute(command);
          } catch (RuntimeException e) {
            log.log(
                Level.SEVERE,
                "RuntimeException while executing runnable " + command + " with executor " + executor,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 19:37:41 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  2. samples/guide/src/main/java/okhttp3/recipes/kt/CacheResponse.kt

          .build()
    
      fun run() {
        val request =
          Request.Builder()
            .url("http://publicobject.com/helloworld.txt")
            .build()
    
        val response1Body =
          client.newCall(request).execute().use {
            if (!it.isSuccessful) throw IOException("Unexpected code $it")
    
            println("Response 1 response:          $it")
            println("Response 1 cache response:    ${it.cacheResponse}")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

                    }
                    fail("Expected connection to be closed")
                  }
                },
            ),
          )
        cancelLater(call, 500)
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertEquals(cancelMode == INTERRUPT, Thread.interrupted())
        }
      }
    
      @ParameterizedTest
      @ArgumentsSource(CancelModelParamProvider::class)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  4. mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt

            .build()
    
        server.enqueue(MockResponse())
    
        val url = server.url("/").newBuilder().host("localhost.localdomain").build()
        val call = client.newCall(Request(url = url))
        val response = call.execute()
        assertThat(response.isSuccessful).isTrue()
    
        val recordedRequest = server.takeRequest()
        assertThat(recordedRequest.handshakeServerNames).containsExactly(url.host)
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  5. docs/pt/docs/advanced/settings.md

            code ->> function: say_hi(name="Rick")
            function ->> execute: executar código da função
            execute ->> code: retornar o resultado
        end
    
        rect rgba(0, 255, 0, .1)
            code ->> function: say_hi(name="Rick", salutation="Mr.")
            function ->> execute: executar código da função
            execute ->> code: retornar o resultado
        end
    
        rect rgba(0, 255, 255, .1)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 17K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/query/BooleanQueryCommand.java

        @Override
        protected String getQueryClassName() {
            return BooleanQuery.class.getSimpleName();
        }
    
        @Override
        public QueryBuilder execute(final QueryContext context, final Query query, final float boost) {
            if (query instanceof final BooleanQuery booleanQuery) {
                if (logger.isDebugEnabled()) {
                    logger.debug("{}:{}", query, boost);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. internal/ioutil/ioutil.go

    		},
    	}
    	ODirectPoolSmall = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(SmallBlock)
    			return &b
    		},
    	}
    )
    
    // WriteOnCloser implements io.WriteCloser and always
    // executes at least one write operation if it is closed.
    //
    // This can be useful within the context of HTTP. At least
    // one write operation must happen to send the HTTP headers
    // to the peer.
    type WriteOnCloser struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ListeningExecutorService service = listeningDecorator(delegate);
        Runnable task =
            new Runnable() {
              @Override
              public void run() {}
            };
        service.execute(task);
        verify(delegate).execute(task);
      }
    
      public void testListeningDecorator_scheduleSuccess() throws Exception {
        final CountDownLatch completed = new CountDownLatch(1);
        ScheduledThreadPoolExecutor delegate =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

                    fail("Expected connection to be closed")
                  }
                },
              )
              .build(),
          )
        interruptLater(500)
        assertFailsWith<IOException> {
          call.execute()
        }
      }
    
      @Test
      fun interruptReadingResponseBody() {
        val responseBodySize = 8 * 1024 * 1024 // 8 MiB.
        server.enqueue(
          MockResponse()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

        }
    
        @Override
        protected String getActionRole() {
            return ROLE;
        }
    
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public HtmlResponse index() {
            saveToken();
            return asListHtml();
        }
    
        @Execute
        @Secured({ ROLE })
        public HtmlResponse upload(final UploadForm form) {
            validate(form, messages -> {}, this::asListHtml);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 28.5K bytes
    - Viewed (0)
Back to top