Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 711 for _state (0.11 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        assertEquals(Service.State.RUNNING, service.state());
    
        exitRun.countDown(); // the service will exit voluntarily
        executionThread.join();
    
        assertTrue(service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
    
        service.stopAsync().awaitTerminated(); // no-op
        assertEquals(Service.State.TERMINATED, service.state());
        assertTrue(service.shutDownCalled);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 19:37:41 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  3. tests/test_dependency_normal_exceptions.py

    
    @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")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Feb 24 23:06:37 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. tests/test_dependency_contextmanager.py

        finally:
            state["context_a"] = "finished a"
    
    
    async def context_b(state: dict = Depends(context_a)):
        state["context_b"] = "started b"
        try:
            yield state
        finally:
            state["context_b"] = f"finished b with a: {state['context_a']}"
    
    
    @app.get("/async")
    async def get_async(state: str = Depends(asyncgen_state)):
        return state
    
    
    @app.get("/sync")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:13:50 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. 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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  6. tests/test_router_events.py

            assert request.state.app
            assert request.state.router
            assert request.state.sub_router
            return {"message": "Hello World"}
    
        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
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 24 19:09:52 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  7. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

    import java.util.concurrent.Executor;
    
    /** Measures the size of AbstractFuture implementations. */
    public class AbstractFutureFootprintBenchmark {
    
      enum State {
        NOT_DONE,
        FINISHED,
        CANCELLED,
        FAILED
      }
    
      @Param State state;
      @Param Impl impl;
    
      @Param({"0", "1", "5", "10"})
      int numListeners;
    
      @Param({"0", "1", "5", "10"})
      int numThreads;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. 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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

          startUpCalled++;
          assertEquals(State.STARTING, state());
        }
    
        @Override
        protected void shutDown() throws Exception {
          assertEquals(1, startUpCalled);
          assertEquals(0, shutDownCalled);
          shutDownCalled++;
          assertEquals(State.STOPPING, state());
        }
    
        @Override
        protected Executor executor() {
          transitionStates.add(state());
          return directExecutor();
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. docs/sts/web-identity.go

    		v.Set("redirect_uri", c.RedirectURL)
    	}
    	if len(c.Scopes) > 0 {
    		v.Set("scope", strings.Join(c.Scopes, " "))
    	}
    	v.Set("state", state)
    	v.Set("nonce", state)
    	if strings.Contains(c.Endpoint.AuthURL, "?") {
    		buf.WriteByte('&')
    	} else {
    		buf.WriteByte('?')
    	}
    	buf.WriteString(v.Encode())
    	return buf.String()
    }
    
    func main() {
    	flag.Parse()
    	if clientID == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
Back to top