Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 491 - 500 of 1,019 for readFn (0.08 seconds)

  1. src/test/java/jcifs/internal/smb1/trans2/Trans2FindNext2Test.java

            trans2FindNext2 = new Trans2FindNext2(config, TEST_SID, TEST_RESUME_KEY, TEST_FILENAME, TEST_BATCH_COUNT, TEST_BATCH_SIZE);
    
            byte[] buffer = new byte[10];
            int read = trans2FindNext2.readParametersWireFormat(buffer, 0, 10);
    
            assertEquals(0, read);
        }
    
        @Test
        void testReadDataWireFormat() {
            // Test data wire format reading (should return 0)
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

        }
    
        /**
         * Reads up to b.length bytes of data from this input stream into an array of bytes.
         *
         * @throws IOException if a network error occurs
         */
    
        @Override
        public int read(final byte[] b) throws IOException {
            return read(b, 0, b.length);
        }
    
        /**
         * Reads up to len bytes of data from this input stream into an array of bytes.
         *
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  3. internal/bucket/bandwidth/monitor_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package bandwidth
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketBandwidthReport) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/RobotsTxtHelper.java

         */
        public RobotsTxt parse(final InputStream stream, final String charsetName) {
            if (!enabled) {
                return null;
            }
    
            BufferedReader reader = null;
            try {
                reader = new BufferedReader(new InputStreamReader(new BOMInputStream(stream), charsetName));
    
                String line;
                final RobotsTxt robotsTxt = new RobotsTxt();
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Fri Nov 14 12:52:01 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectResponseTest.java

            int read3 = response.readBytesWireFormat(buffer, 0);
    
            // Then - all reads should return same result
            assertEquals(4, read1);
            assertEquals(4, read2);
            assertEquals(4, read3);
        }
    
        @Test
        @DisplayName("Should validate structure size before processing")
        void testStructureSizeValidation() {
            // Given various invalid structure sizes
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/suggest/entity/ElevateWordTest.java

            assertEquals(0, itemReadings.length);
        }
    
        @Test
        public void testToSuggestItemWithSingleReading() {
            // Test toSuggestItem with single reading
            String word = "single reading";
            float boost = 1.5f;
            List<String> readings = Arrays.asList("reading1");
            List<String> fields = Arrays.asList("field1");
            List<String> tags = Arrays.asList("tag1");
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Mon Sep 01 13:33:03 GMT 2025
    - 16K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/dict/kuromoji/AdminDictKuromojiAction.java

                }, this::asEditHtml);
            }
            if (form.segmentation != null && form.reading != null && form.segmentation.split(" ").length != form.reading.split(" ").length) {
                throwValidationError(messages -> {
                    messages.addErrorsInvalidKuromojiSegmentation("segmentation", form.segmentation, form.reading);
                }, this::asEditHtml);
            }
        }
    
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 21.5K bytes
    - Click Count (0)
  8. impl/maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java

            // [01] clean:clean
            // [02] modello:xpp3-writer
            // [03] modello:java
            // [04] modello:xpp3-reader
            // [05] modello:xpp3-writer
            // [06] modello:java
            // [07] modello:xpp3-reader
            // [08] plugin:descriptor
            // [09] resources:resources
            // [10] compiler:compile
            // [11] resources:testResources
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 22.9K bytes
    - Click Count (0)
  9. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

    import okio.ByteString
    import okio.ByteString.Companion.decodeHex
    import okio.FileSystem
    import okio.Path
    import okio.Path.Companion.toOkioPath
    import okio.buffer
    import okio.source
    
    /**
     * Utilities for reading HPACK tests.
     */
    object HpackJsonUtil {
      @Suppress("unused")
      private val MOSHI =
        Moshi
          .Builder()
          .add(
            object : Any() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  10. samples/guide/src/main/java/okhttp3/recipes/kt/PostFile.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.RequestBody.Companion.asRequestBody
    
    class PostFile {
      private val client = OkHttpClient()
    
      fun run() {
        val file = File("README.md")
    
        val request =
          Request(
            url = "https://api.github.com/markdown/raw".toHttpUrl(),
            body = file.asRequestBody(MEDIA_TYPE_MARKDOWN),
          )
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.4K bytes
    - Click Count (0)
Back to Top