Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 1,652 for writeFn (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/store/queuestore.go

    	return err
    }
    
    // write - writes an item to the directory.
    func (store *QueueStore[I]) write(key Key, item I) error {
    	// Marshals the item.
    	eventData, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    	return store.writeBytes(key, eventData)
    }
    
    // writeBytes - writes bytes to the directory.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. src/archive/tar/reader_test.go

    				}
    			case testWriteTo:
    				f := &testFile{ops: tf.ops}
    				got, err := fr.WriteTo(f)
    				if _, ok := err.(testError); ok {
    					t.Errorf("test %d.%d, WriteTo(): %v", i, j, err)
    				} else if got != tf.wantCnt || err != tf.wantErr {
    					t.Errorf("test %d.%d, WriteTo() = (%d, %v), want (%d, %v)", i, j, got, err, tf.wantCnt, tf.wantErr)
    				}
    				if len(f.ops) > 0 {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Dec 30 15:28:53 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/io/Smb2FlushResponseTest.java

                SMBUtil.writeInt2(0, readBuffer, 12);
    
                // When
                int written = response.writeBytesWireFormat(writeBuffer, 5);
                int read = response.readBytesWireFormat(readBuffer, 10);
    
                // Then
                assertEquals(0, written);
                assertEquals(4, read);
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb2/Smb2CancelRequestTest.java

            // When
            int bytesWritten = request.writeBytesWireFormat(buffer, offset);
    
            // Then
            assertEquals(4, bytesWritten, "Should write 4 bytes");
            // Check that structure size (4) is written as 2-byte little-endian
            assertEquals(4, buffer[offset] | (buffer[offset + 1] << 8), "Structure size should be 4");
            assertEquals(0, buffer[offset + 2], "Reserved bytes should be 0");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.8K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb1/trans2/Trans2FindFirst2Test.java

        void testWriteSetupWireFormat() {
            trans2FindFirst2 = new Trans2FindFirst2(mockConfig, "\\test", "*.*", 0x16, 10, 1024);
    
            byte[] buffer = new byte[10];
            int written = trans2FindFirst2.writeSetupWireFormat(buffer, 0);
    
            assertEquals(2, written);
            assertEquals((byte) Trans2FindFirst2.TRANS2_FIND_FIRST2, buffer[0]);
            assertEquals((byte) 0x00, buffer[1]);
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  6. misc/go_android_exec/exitcode_test.go

    	"testing"
    )
    
    func TestExitCodeFilter(t *testing.T) {
    	// Write text to the filter one character at a time.
    	var out strings.Builder
    	f, exitStr := newExitCodeFilter(&out)
    	// Embed a "fake" exit code in the middle to check that we don't get caught on it.
    	pre := "abc" + exitStr + "123def"
    	text := pre + exitStr + `1`
    	for i := 0; i < len(text); i++ {
    		_, err := f.Write([]byte{text[i]})
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed May 03 14:54:58 GMT 2023
    - 2.1K bytes
    - Click Count (0)
  7. cmd/batch-replicate_gen.go

    func (z BatchJobReplicateCredentials) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "AccessKey"
    	err = en.Append(0x83, 0xa9, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4b, 0x65, 0x79)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.AccessKey)
    	if err != nil {
    		err = msgp.WrapError(err, "AccessKey")
    		return
    	}
    	// write "SecretKey"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.7K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/io/CharSource.java

        }
    
        @Override
        public long copyTo(CharSink sink) throws IOException {
          checkNotNull(sink);
          Closer closer = Closer.create();
          try {
            Writer writer = closer.register(sink.openStream());
            writer.write((String) seq);
            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 25.7K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/api/BaseApiManager.java

            return FormatType.OTHER;
        }
    
        /**
         * Writes text content to the HTTP response with specified content type and encoding.
         * @param text The text content to write.
         * @param contentType The content type for the response.
         * @param encoding The character encoding for the response.
         */
        protected void write(final String text, final String contentType, final String encoding) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

                    writeFesenCat(zos, diagnosticId);
                    writeFesenJson(zos, diagnosticId);
                }
            });
        }
    
        /**
         * Writes OpenSearch JSON API responses to the ZIP output stream.
         *
         * @param zos the ZIP output stream to write to
         * @param id the diagnostic ID for organizing files in the ZIP
         */
        protected void writeFesenJson(final ZipOutputStream zos, final String id) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 23K bytes
    - Click Count (0)
Back to Top