Search Options

Results per page
Sort
Preferred Languages
Advance

Results 811 - 820 of 1,349 for Pread (0.02 sec)

  1. internal/pubsub/pubsub.go

    				} else {
    					remainTypes.Merge(s.types)
    				}
    			}
    			atomic.StoreUint64(&ps.types, uint64(remainTypes))
    			atomic.AddInt32(&ps.numSubscribers, -1)
    		}()
    
    		// Read from subChT and write to subCh
    		var buf bytes.Buffer
    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-doneCh:
    				return
    			case v, ok := <-subChT:
    				if !ok {
    					return
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // Deprecated: selfLink is a legacy read-only field that is no longer populated by the system.
      // +optional
      optional string selfLink = 4;
    
      // UID is the unique in time and space value for this object. It is typically generated by
      // the server on successful creation of a resource and is not allowed to change on PUT
      // operations.
      //
      // Populated by the system.
      // Read-only.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  3. docs/en/docs/fastapi-people.md

    {% endfor %}
    
    </div>
    {% endif %}
    
    I'm the creator of **FastAPI**. You can read more about that in [Help FastAPI - Get Help - Connect with the author](help-fastapi.md#connect-with-the-author){.internal-link target=_blank}.
    
    ...But here I want to show you the community.
    
    ---
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			break
    		}
    
    		stat = append(stat, st)
    	}
    
    	return stat, toStorageErr(err)
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context or network errors returns an error.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/hash/BloomFilterTest.java

        }
    
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        bf.writeTo(out);
    
        BloomFilter<byte[]> read =
            BloomFilter.readFrom(new ByteArrayInputStream(out.toByteArray()), funnel);
        assertThat(read).isEqualTo(bf);
        assertThat(read.expectedFpp()).isGreaterThan(0);
      }
    
      /**
       * This test will fail whenever someone updates/reorders the BloomFilterStrategies constants. Only
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. internal/logger/target/http/http.go

    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// If this webhook is being re-configured we will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/google/MultisetElementSetTester.java

      @CollectionFeature.Require(SUPPORTS_REMOVE)
      public void testElementSetClear() {
        getMultiset().elementSet().clear();
        assertEmpty(getMultiset());
      }
    
      /**
       * Returns {@link Method} instances for the read tests that assume multisets support duplicates so
       * that the test of {@code Multisets.forSet()} can suppress them.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  8. CONTRIBUTING.md

    ``MinIO`` community welcomes your contribution. To make the process as seamless as possible, we recommend you read this contribution guide.
    
    ## Development Workflow
    
    Start by forking the MinIO GitHub repository, make changes in a branch and then send a pull request. We encourage pull requests to discuss code changes. Here are the steps in details:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. .github/workflows/build-docs.yml

        types:
          - opened
          - synchronize
    
    env:
      UV_SYSTEM_PYTHON: 1
    
    jobs:
      changes:
        runs-on: ubuntu-latest
        # Required permissions
        permissions:
          pull-requests: read
        # Set job outputs to values from filter step
        outputs:
          docs: ${{ steps.filter.outputs.docs }}
        steps:
        - uses: actions/checkout@v4
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 12:27:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. tests/test_tutorial/test_cookie_param_models/test_tutorial002.py

                "openapi": "3.1.0",
                "info": {"title": "FastAPI", "version": "0.1.0"},
                "paths": {
                    "/items/": {
                        "get": {
                            "summary": "Read Items",
                            "operationId": "read_items_items__get",
                            "parameters": [
                                {
                                    "name": "session_id",
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top