Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 543 for State (0.14 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractService.java

                  + this
                  + " to reach a terminal state. "
                  + "Current state: "
                  + state());
        }
      }
    
      /** Checks that the current state is equal to the expected state. */
      @GuardedBy("monitor")
      private void checkCurrentState(State expected) {
        State actual = state();
        if (actual != expected) {
          if (actual == FAILED) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  2. .teamcity/pluginData/Check/plugin-settings.xml

          <states>
            <state type="buildAddedToQueue" enabled="false" />
            <state type="buildRemovedFromQueue" enabled="true" />
            <state type="buildStarted" enabled="true" />
            <state type="changesLoaded" enabled="true" />
            <state type="buildInterrupted" enabled="true" />
            <state type="beforeBuildFinish" enabled="false" />
            <state type="buildFinished" enabled="true" />
    XML
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Tue May 18 02:15:16 GMT 2021
    - 2.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/AbstractIterator.java

      }
    
      private boolean tryToComputeNext() {
        state = State.FAILED; // temporary pessimism
        next = computeNext();
        if (state != State.DONE) {
          state = State.READY;
          return true;
        }
        return false;
      }
    
      @CanIgnoreReturnValue // TODO(kak): Should we remove this?
      @Override
      @ParametricNullness
      public final T next() {
        if (!hasNext()) {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri Mar 18 02:04:10 GMT 2022
    - 6.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

              public void failed(State from, Throwable failure) {
                assertEquals(State.RUNNING, from);
                assertEquals(error, failure);
                latch.countDown();
              }
            },
            directExecutor());
        service.startAsync();
        latch.await();
    
        assertEquals(0, service.numberOfTimesRunCalled.get());
        assertEquals(Service.State.FAILED, service.state());
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  5. tests/test_router_events.py

        app.include_router(router)
    
        assert state.app_startup is False
        assert state.router_startup is False
        assert state.sub_router_startup is False
        assert state.app_shutdown is False
        assert state.router_shutdown is False
        assert state.sub_router_shutdown is False
        with TestClient(app) as client:
            assert state.app_startup is True
            assert state.router_startup is True
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Wed Oct 18 12:36:40 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/AbstractIterator.java

      }
    
      private boolean tryToComputeNext() {
        state = State.FAILED; // temporary pessimism
        next = computeNext();
        if (state != State.DONE) {
          state = State.READY;
          return true;
        }
        return false;
      }
    
      @CanIgnoreReturnValue // TODO(kak): Should we remove this?
      @Override
      @ParametricNullness
      public final T next() {
        if (!hasNext()) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Mar 18 02:04:10 GMT 2022
    - 6.4K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        state = STATE_WRITING_REQUEST_BODY
        return ChunkedSink()
      }
    
      private fun newKnownLengthSink(): Sink {
        check(state == STATE_OPEN_REQUEST_BODY) { "state: $state" }
        state = STATE_WRITING_REQUEST_BODY
        return KnownLengthSink()
      }
    
      private fun newFixedLengthSource(length: Long): Source {
        check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" }
        state = STATE_READING_RESPONSE_BODY
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  8. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

      private static final Logger log = Logger.getLogger(AbstractFuture.class.getName());
    
      private State state;
      private V value;
      private @Nullable Future<? extends V> delegate;
      private @Nullable Throwable throwable;
      private boolean mayInterruptIfRunning;
      private List<Listener> listeners;
    
      protected AbstractFuture() {
        state = State.PENDING;
        listeners = new ArrayList<Listener>();
      }
    
      @CanIgnoreReturnValue
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jan 22 19:37:41 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/AbstractIterator.java

        checkState(state != State.FAILED);
        switch (state) {
          case DONE:
            return false;
          case READY:
            return true;
          default:
        }
        return tryToComputeNext();
      }
    
      private boolean tryToComputeNext() {
        state = State.FAILED; // temporary pessimism
        next = computeNext();
        if (state != State.DONE) {
          state = State.READY;
          return true;
        }
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri Jul 09 17:31:04 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  10. tests/test_dependency_normal_exceptions.py

        return {"message": "OK"}
    
    
    @pytest.fixture(autouse=True)
    def reset_state_and_db():
        global fake_database
        global state
        fake_database = initial_fake_database.copy()
        state = initial_state.copy()
    
    
    client = TestClient(app)
    
    
    def test_dependency_gets_exception():
        assert state["except"] is False
        assert state["finally"] is False
        response = client.put("/invalid-user/rick", json="Morty")
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sat Feb 24 23:06:37 GMT 2024
    - 1.9K bytes
    - Viewed (0)
Back to top