Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 527 for channels (0.12 sec)

  1. guava/src/com/google/common/collect/Lists.java

        return new CopyOnWriteArrayList<>(elementsCollection);
      }
    
      /**
       * Returns an unmodifiable list containing the specified first element and backed by the specified
       * array of additional elements. Changes to the {@code rest} array will be reflected in the
       * returned list. Unlike {@link Arrays#asList}, the returned list is unmodifiable.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 43.1K bytes
    - Viewed (0)
  2. docs/bigdata/README.md

    - [https://hadoop.apache.org/docs/r3.1.1/hadoop-aws/tools/hadoop-aws/committers.html](https://hadoop.apache.org/docs/r3.1.1/hadoop-aws/tools/hadoop-aws/committers.html)
    
    Once the config changes are applied, proceed to restart **Hadoop** services.
    
    ![hdfs-services](https://github.com/minio/minio/blob/master/docs/bigdata/images/image7.png?raw=true "hdfs restart services")
    
    ### **3.2 Configure Spark2**
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  3. samples/guide/src/main/java/okhttp3/recipes/kt/YubikeyClientAuth.kt

    import okhttp3.internal.platform.Platform
    
    /**
     * Example of using a hardware key to perform client auth.
     * Prefer recent JDK builds, and results are temperamental to slight environment changes.
     * Different instructions and configuration may be required for other hardware devices.
     *
     * Using a yubikey device as a SSL key store.
     * https://lauri.võsandi.com/2017/03/yubikey-for-ssh-auth.html
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. internal/event/target/nsq.go

    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/ArrayListMultimapTest.java

        assertTrue(multimap.replaceValues("bar", asList(2, 4)) instanceof RandomAccess);
      }
    
      /** Test throwing ConcurrentModificationException when a sublist's ancestor's delegate changes. */
      public void testSublistConcurrentModificationException() {
        ListMultimap<String, Integer> multimap = create();
        multimap.putAll("foo", asList(1, 2, 3, 4, 5));
        List<Integer> list = multimap.get("foo");
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. docs/bucket/versioning/DESIGN.md

              "etag": "20000f00f58c508b40720270929bd90e9f07b9bd78fb605e5432a67635fc34722e4fc53b1d5fab9ff8400eb9ded4fba2"
            }
          }
        }
      ]
    }
    ```
    
    ### v1.3+ versions
    
    Version 1.3 introduces changes to help with [faster metadata reads and updates](https://blog.min.io/minio-versioning-metadata-deep-dive/)
    
    | Entry           | Encoding                    | Content
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  7. .github/ISSUE_TEMPLATE/feature_enhancement_request.yaml

          value: >
            Did you *actually* encounter the need for this enhancement in a real-world scenario, or does
            it just seem like a sensible behavior for the feature to have?
    
    
            Before we make significant changes to existing features in Guava, we really want to be sure
            that it's for a use case that actually comes up in the real world. We want to hear the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Nov 17 18:47:47 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Multimaps.java

          Map<K, Collection<V>> asMap(Multimap<K, V> multimap) {
        return multimap.asMap();
      }
    
      /**
       * Returns a multimap view of the specified map. The multimap is backed by the map, so changes to
       * the map are reflected in the multimap, and vice versa. If the map is modified while an
       * iteration over one of the multimap's collection views is in progress (except through the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  9. internal/cachevalue/cache.go

    	t.Once.Do(func() {
    		t.ttl = ttl
    		t.updateFn = update
    		t.opts = opts
    	})
    }
    
    // GetWithCtx will return a cached value or fetch a new one.
    // passes a caller context, if caller context cancels nothing
    // is cached.
    // If the Update function returns an error the value is forwarded as is and not cached.
    func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) {
    	v := t.val.Load()
    	ttl := t.ttl
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. internal/grid/muxserver.go

    			handlerErr = &err
    		}
    		if debugPrint {
    			fmt.Println("muxServer: Mux", m.ID, "Returned with", handlerErr)
    		}
    	}()
    	// handlerErr is guarded by 'send' channel.
    	handlerErr = handler.Handle(ctx, msg.Payload, handlerIn, send)
    	return handlerErr
    }
    
    // checkRemoteAlive will check if the remote is alive.
    func (m *muxServer) checkRemoteAlive() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top