- Sort Score
- Num 10 results
- Language All
Results 571 - 580 of 749 for channels (0.15 seconds)
-
guava/src/com/google/common/collect/TopKSelector.java
* fewer than {@code k} have been offered, in the order specified by the factory used to create * this {@code TopKSelector}. * * <p>The returned list is an unmodifiable copy and will not be affected by further changes to * this {@code TopKSelector}. This method returns in O(k log k) time. */ public List<T> topK() { @SuppressWarnings("nullness") // safe because we pass sort() a range that contains real TsCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Aug 31 13:15:26 GMT 2025 - 11.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/io/Smb2WriteRequestTest.java
assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, headerStart + 16, headerStart + 32)); // File ID assertEquals(0, SMBUtil.readInt4(buffer, headerStart + 32)); // Channel assertEquals(500, SMBUtil.readInt4(buffer, headerStart + 36)); // Remaining bytes assertEquals(0, SMBUtil.readInt2(buffer, headerStart + 40)); // WriteChannelInfoOffset
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 22.4K bytes - Click Count (0) -
internal/s3select/jstream/decoder.go
// containing those values is emitted. func (d *Decoder) Recursive() *Decoder { d.emitRecursive = true return d } // Stream begins decoding from the underlying reader and returns a // streaming MetaValue channel for JSON values at the configured emitDepth. func (d *Decoder) Stream() chan *MetaValue { go d.decode() return d.metaCh } // Pos returns the number of bytes consumed from the underlying reader
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
import org.codelibs.fess.opensearch.user.exentity.User; /** * Authentication chain implementation that executes external commands for user operations. * Provides user management through command-line tool execution for password changes and user deletion. */ public class CommandChain implements AuthenticationChain { private static final Logger logger = LogManager.getLogger(CommandChain.class); /** Working directory for command execution. */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessTimeResourceProviderTest.java
assertEquals(provider1, provider1); // Self equality assertFalse(provider1.equals(null)); // Null check assertFalse(provider1.equals("string")); // Type check } // Test with rapid config changes @Test public void test_rapidConfigChanges() { for (int i = 0; i < 50; i++) { final int adjustment = i * 1000; FessConfig rapidConfig = new FessConfig.SimpleImpl() {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 17.8K bytes - Click Count (0) -
architecture/standards/0006-use-of-provider-apis-in-gradle.md
// This should be always: String value = getSomeProperty().get() ``` ## Consequences * We are incurring debt that will need to be paid later via deprecations or breaking changes to existing classes. The implementation for some Gradle types will be more complicated than an equivalent clean-sheet implementation.
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Mar 05 12:39:41 GMT 2026 - 10K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java
TransPeekNamedPipeResponse testResponse = new TransPeekNamedPipeResponse(testConfig); // Assert assertNotNull(testResponse); } @Test @DisplayName("Test state changes after reading parameters") void testStateAfterReadingParameters() { // Arrange byte[] buffer = new byte[10]; SMBUtil.writeInt2(1500, buffer, 0); SMBUtil.writeInt2(0xFFFF, buffer, 2);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.8K bytes - Click Count (0) -
docs/distributed/README.md
export MINIO_ROOT_PASSWORD=<SECRET_KEY> minio server http://host{1...n}/export{1...m} ``` > **NOTE:** In above example `n` and `m` represent positive integers, _do not copy paste and expect it work make the changes according to local deployment and setup_.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 8.9K bytes - Click Count (0) -
ADDING_NEW_LANGUAGE.md
**Example directory structure:** ``` dictionary/ └── sv/ ├── stopwords.txt ├── stemmer_override.txt └── protwords.txt ``` ## Important Notes ### No Database Changes Required - Language configuration is entirely file-based - No database or OpenSearch index updates needed - Settings are loaded at application startup and cached ### Fallback MechanismCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 06 11:36:30 GMT 2025 - 10.4K bytes - Click Count (1) -
architecture/standards/0010-gradle-properties-naming.md
### Terminology **Public properties** are formally a part of the Public API. Public properties are **stable properties**: they CANNOT be renamed or removed without notice. While we normally deprecate the feature or behavior itself, changes to the property cannot happen in a minor release. Public properties must be documented. **Internal properties** are not part of the Public API.
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 06 09:25:54 GMT 2026 - 8K bytes - Click Count (0)