Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 1,693 for written (0.06 sec)

  1. guava-tests/test/com/google/common/io/CharStreamsTest.java

      }
    
      public void testNullWriter() throws Exception {
        // create a null writer
        Writer nullWriter = CharStreams.nullWriter();
        // write to the writer
        nullWriter.write('n');
        String test = "Test string for NullWriter";
        nullWriter.write(test);
        nullWriter.write(test, 2, 10);
        nullWriter.append(null);
        nullWriter.append(null, 0, 4);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/MultipartBodyTest.kt

        val buffer = Buffer()
        body.writeTo(buffer)
        assertThat(buffer.readUtf8()).isEqualTo(expected)
      }
    
      @Test
      fun streamingPartHasNoLength() {
        class StreamingBody(private val body: String) : RequestBody() {
          override fun contentType(): MediaType? {
            return null
          }
    
          @Throws(IOException::class)
          override fun writeTo(sink: BufferedSink) {
            sink.writeUtf8(body)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. cmd/bucket-replication-metrics_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z ActiveWorkerStat) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "Curr"
    	err = en.Append(0x83, 0xa4, 0x43, 0x75, 0x72, 0x72)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Curr)
    	if err != nil {
    		err = msgp.WrapError(err, "Curr")
    		return
    	}
    	// write "Avg"
    	err = en.Append(0xa3, 0x41, 0x76, 0x67)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance_gen.go

    func (z rebalanceInfo) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "startTs"
    	err = en.Append(0x83, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x73)
    	if err != nil {
    		return
    	}
    	err = en.WriteTime(z.StartTime)
    	if err != nil {
    		err = msgp.WrapError(err, "StartTime")
    		return
    	}
    	// write "stopTs"
    	err = en.Append(0xa6, 0x73, 0x74, 0x6f, 0x70, 0x54, 0x73)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer_test.go

    			writeRng.Read(buf)
    			// Write
    			n, err := rb.Write(buf[:writeRng.Intn(len(buf))])
    			if err != nil {
    				t.Fatalf("write failed: %v", err)
    			}
    			wroteBytes += n
    			wrote.Write(buf[:n])
    			debugln("WRITE 1\t", n, wroteBytes)
    
    			// WriteString
    			n, err = rb.WriteString(string(buf[:writeRng.Intn(len(buf))]))
    			if err != nil {
    				t.Fatalf("write failed: %v", err)
    			}
    			wroteBytes += n
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  6. internal/grid/msg_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "ID"
    	err = en.Append(0x84, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteBytes((z.ID)[:])
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "Host"
    	err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74)
    	if err != nil {
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 22.4K bytes
    - Viewed (0)
  7. compat/maven-model-builder/src/test/java/org/apache/maven/model/inheritance/DefaultInheritanceAssemblerTest.java

            Model assembled = assembler.assembleModelInheritance(child, parent, null, problems);
    
            // write baseName + "-actual"
            File actual = new File(
                    "target/test-classes/poms/inheritance/" + baseName + (fromRepo ? "-build" : "-repo") + "-actual.xml");
            writer.write(actual, null, assembled);
    
            // check with getPom( baseName + "-expected" )
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. internal/lsync/lrwmutex_test.go

    	lrwm := NewLRWMutex()
    
    	// fmt.Println("Getting initial write lock")
    	if !lrwm.GetLock(ctx, "", "", time.Second) {
    		panic("Failed to acquire initial write lock")
    	}
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.Unlock()
    		// fmt.Println("Initial write lock released, waiting...")
    	}()
    
    	// fmt.Println("Trying to acquire 2nd write lock, waiting...")
    	locked = lrwm.GetLock(ctx, "", "", duration)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/io/CharSourceTester.java

        Reader reader = source.openStream();
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertExpectedString(writer.toString());
      }
    
      public void testOpenBufferedStream() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  10. istioctl/pkg/describe/describe.go

    			cfgNames += ", "
    		}
    	}
    	fmt.Fprintf(writer, "   %s\n", cfgNames)
    }
    
    func printPeerAuthentication(writer io.Writer, pa authn.MergedPeerAuthentication) {
    	fmt.Fprintf(writer, "Effective PeerAuthentication:\n")
    	fmt.Fprintf(writer, "   Workload mTLS mode: %s\n", pa.Mode.String())
    	if len(pa.PerPort) != 0 {
    		fmt.Fprintf(writer, "   Port Level mTLS mode:\n")
    		for port, mode := range pa.PerPort {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top