Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 627 for nwait (0.03 sec)

  1. internal/s3select/message.go

    		close(writer.payloadCh)
    		// Wait until the `start` go-routine is done.
    		<-writer.doneCh
    		return nil
    	}
    }
    
    func (writer *messageWriter) FinishWithError(errorCode, errorMessage string) error {
    	select {
    	case <-writer.doneCh:
    		return fmt.Errorf("messageWriter is done")
    	case writer.errCh <- newErrorMessage([]byte(errorCode), []byte(errorMessage)):
    		// Wait until the `start` go-routine is done.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  2. .github/DISCUSSION_TEMPLATE/questions.yml

            By asking questions in a structured way (following this) it will be much easier to help you.
    
            And there's a high chance that you will find the solution along the way and you won't even have to submit it and wait for an answer. ๐Ÿ˜Ž
    
            As there are too many questions, I'll have to discard and close the incomplete ones. That will allow me (and others) to focus on helping people like you that follow the whole process and help us help you. ๐Ÿค“
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Aug 03 15:59:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  3. docs/pl/docs/index.md

        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Albo uลผyj <code>async def</code>...</summary>
    
    Jeลผeli twรณj kod korzysta z `async` / `await`, uลผyj `async def`:
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

            var first = true
    
            override fun createSocket(): Socket {
              if (first) {
                first = false
                firstConnectLatch.await()
              }
              return super.createSocket()
            }
          }
    
        client =
          client.newBuilder()
            .protocols(listOf(Protocol.H2_PRIOR_KNOWLEDGE))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. cmd/iam-object-store.go

    				return fmt.Errorf("unable to load the user `%s`: %w", userName, err)
    			}
    			userIdentities[index] = user
    			return nil
    		}, index)
    	}
    
    	err := errors.Join(g.Wait()...)
    	return userIdentities, err
    }
    
    func (iamOS *IAMObjectStore) loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error {
    	u, err := iamOS.loadUserIdentity(ctx, user, userType)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    	if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) {
    		go globalBootstrapTracer.Publish(ctx, globalTrace)
    	}
    
    	// Wait for remote to cancel and SubscribeJSON to exit.
    	wg.Wait()
    	return nil
    }
    
    func (s *peerRESTServer) BackgroundHealStatusHandler(_ *grid.MSS) (*grid.JSON[madmin.BgHealState], *grid.RemoteErr) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  7. docs/ko/docs/tutorial/background-tasks.md

    ๋ฐฑ๊ทธ๋ผ์šด๋“œ ์ž‘์—…์œผ๋กœ ์‹คํ–‰ํ•  ํ•จ์ˆ˜๋ฅผ ์ •์˜ํ•ฉ๋‹ˆ๋‹ค.
    
    ์ด๊ฒƒ์€ ๋‹จ์ˆœํžˆ ๋งค๊ฐœ๋ณ€์ˆ˜๋ฅผ ๋ฐ›์„ ์ˆ˜ ์žˆ๋Š” ํ‘œ์ค€ ํ•จ์ˆ˜์ผ ๋ฟ์ž…๋‹ˆ๋‹ค.
    
    **FastAPI**๋Š” ์ด๊ฒƒ์ด `async def` ํ•จ์ˆ˜์ด๋“ , ์ผ๋ฐ˜ `def` ํ•จ์ˆ˜์ด๋“  ๋‚ด๋ถ€์ ์œผ๋กœ ์ด๋ฅผ ์˜ฌ๋ฐ”๋ฅด๊ฒŒ ์ฒ˜๋ฆฌํ•ฉ๋‹ˆ๋‹ค.
    
    ์ด ๊ฒฝ์šฐ, ์•„๋ž˜ ์ž‘์—…์€ ํŒŒ์ผ์— ์“ฐ๋Š” ํ•จ์ˆ˜์ž…๋‹ˆ๋‹ค. (์ด๋ฉ”์ผ ๋ณด๋‚ด๊ธฐ ์‹œ๋ฌผ๋ ˆ์ด์…˜)
    
    ๊ทธ๋ฆฌ๊ณ  ์ด ์ž‘์—…์€ `async`์™€ `await`๋ฅผ ์‚ฌ์šฉํ•˜์ง€ ์•Š์œผ๋ฏ€๋กœ ์ผ๋ฐ˜ `def` ํ•จ์ˆ˜๋กœ ์„ ์–ธํ•ฉ๋‹ˆ๋‹ค.
    
    ```Python hl_lines="6-9"
    {!../../docs_src/background_tasks/tutorial001.py!}
    ```
    
    ## ๋ฐฑ๊ทธ๋ผ์šด๋“œ ์ž‘์—… ์ถ”๊ฐ€
    
    _๊ฒฝ๋กœ ์ž‘๋™ ํ•จ์ˆ˜_ ๋‚ด์—์„œ ์ž‘์—… ํ•จ์ˆ˜๋ฅผ `.add_task()` ํ•จ์ˆ˜ ํ†ตํ•ด _๋ฐฑ๊ทธ๋ผ์šด๋“œ ์ž‘์—…_ ๊ฐœ์ฒด์— ์ „๋‹ฌํ•ฉ๋‹ˆ๋‹ค.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. docs/nl/docs/index.md

        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Of maak gebruik van <code>async def</code>...</summary>
    
    Als je code gebruik maakt van `async` / `await`, gebruik dan `async def`:
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  9. docs/em/docs/tutorial/dependencies/index.md

    โšซ๏ธ ๐Ÿšซ ๐Ÿค”. **FastAPI** ๐Ÿ”œ ๐Ÿ’ญ โšซ๏ธโ”.
    
    /// note
    
    ๐Ÿšฅ ๐Ÿ‘† ๐Ÿšซ ๐Ÿ’ญ, โœ… [๐Ÿ”: *"๐Ÿƒ โ“" *](../../async.md){.internal-link target=_blank} ๐Ÿ“„ ๐Ÿ”ƒ `async` &amp; `await` ๐Ÿฉบ.
    
    ///
    
    ## ๐Ÿ› ๏ธ โฎ๏ธ ๐Ÿ—„
    
    ๐ŸŒ ๐Ÿ“จ ๐Ÿ“„, ๐Ÿ”ฌ &amp; ๐Ÿ“„ ๐Ÿ‘† ๐Ÿ”— (&amp; ๐ŸŽง-๐Ÿ”—) ๐Ÿ”œ ๐Ÿ› ๏ธ ๐ŸŽ ๐Ÿ—„ ๐Ÿ”—.
    
    , ๐ŸŽ“ ๐Ÿฉบ ๐Ÿ”œ โœ”๏ธ ๐ŸŒ โ„น โšช๏ธโžก๏ธ ๐Ÿ‘ซ ๐Ÿ”— ๐Ÿ’โ€โ™‚๏ธ:
    
    <img src="/img/tutorial/dependencies/image01.png">
    
    ## ๐Ÿ™… โš™๏ธ
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. internal/grid/muxclient.go

    		defer cancel()
    	}
    	// Send request
    	if err := m.send(msg); err != nil {
    		return nil, err
    	}
    	if debugReqs {
    		fmt.Println(m.MuxID, m.parent.String(), "SEND")
    	}
    	// Wait for response or context.
    	select {
    	case v, ok := <-ch:
    		if !ok {
    			return nil, ErrDisconnected
    		}
    		if debugReqs && v.Err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
Back to top