Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 997 for read$3 (0.09 sec)

  1. src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java

            final List<CharMappingItem> itemList = new ArrayList<>();
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
                long id = 0;
                String line = null;
                while ((line = reader.readLine()) != null) {
                    // Remove comments
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. samples/guide/src/main/java/okhttp3/guide/GetExample.java

        }
      }
    
      public static void main(String[] args) throws IOException {
        GetExample example = new GetExample();
        String response = example.run("https://raw.github.com/square/okhttp/master/README.md");
        System.out.println(response);
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  3. CHANGELOG.md

    CHANGELOG/README.md...
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Jan 05 07:53:04 UTC 2023
    - 19 bytes
    - Viewed (0)
  4. internal/deadlineconn/deadlineconn.go

    			c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval))
    			c.writeSetAt = now
    		}
    	}
    }
    
    // Read - reads data from the connection using wrapped buffered reader.
    func (c *DeadlineConn) Read(b []byte) (n int, err error) {
    	c.setReadDeadline()
    	n, err = c.Conn.Read(b)
    	return n, err
    }
    
    // Write - writes data to the connection.
    func (c *DeadlineConn) Write(b []byte) (n int, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. docs/debugging/inspect/main.go

    			fmt.Println("Using private key from", *privKeyPath)
    		}
    
    		// Prompt for decryption key if no --key or --private-key are provided
    		if len(privateKey) == 0 && !*stdin {
    			reader := bufio.NewReader(os.Stdin)
    			fmt.Print("Enter Decryption Key: ")
    
    			text, _ := reader.ReadString('\n')
    			// convert CRLF to LF
    			*keyHex = strings.ReplaceAll(text, "\n", "")
    			*keyHex = strings.TrimSpace(*keyHex)
    		}
    	}
    
    	var inputs []string
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 31 14:49:23 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

                    cf.not(subCf -> subCf.setId_InScope(idList));
                }
            }));
        }
    
        public void importCsv(final Reader reader) {
            @SuppressWarnings("resource")
            final CsvReader csvReader = new CsvReader(reader, new CsvConfig());
            final DateFormat formatter = new SimpleDateFormat(CoreLibConstants.DATE_FORMAT_ISO_8601_EXTEND);
            try {
                List<String> list;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  7. .github/workflows/sigbuild-docker-branch.yml

      push:
        paths:
          - '.github/workflows/sigbuild-docker-branch.yml'
          - 'tensorflow/tools/tf_sig_build_dockerfiles/**'
          - '!tensorflow/tools/tf_sig_build_dockerfiles/README.md'
        branches:
          - "r[1-9].[0-9]+"
    
    permissions:
      contents: read
    
    jobs:
      docker:
        if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks
        runs-on: ubuntu-latest
        strategy:
          matrix:
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

          // Replace the body with a stripped one so the callbacks can't see real data.
          val response = response.stripBody()
    
          val reader = ServerSentEventReader(body.source(), this)
          try {
            if (!canceled) {
              listener.onOpen(this, response)
              while (!canceled && reader.processNextEvent()) {
              }
            }
          } catch (e: Exception) {
            val exception =
              when {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. internal/rest/client.go

    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    				return io.NopCloser(&r), nil
    			}
    		case *strings.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  10. internal/s3select/parquet/args.go

    package parquet
    
    import "encoding/xml"
    
    // ReaderArgs - represents elements inside <InputSerialization><Parquet/> in request XML.
    type ReaderArgs struct {
    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
Back to top