Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 660 for buffered (0.05 sec)

  1. istioctl/pkg/writer/envoy/configdump/ecds_test.go

    )
    
    func TestPrintEcdsSummary(t *testing.T) {
    	gotOut := &bytes.Buffer{}
    	cw := &ConfigWriter{Stdout: gotOut}
    	cd, _ := os.ReadFile("testdata/ecds/configdump.json")
    	cw.Prime(cd)
    	err := cw.PrintEcdsSummary()
    	assert.NoError(t, err)
    
    	util.CompareContent(t, gotOut.Bytes(), "testdata/ecds/output.txt")
    }
    
    func TestPrintEcdsYaml(t *testing.T) {
    	gotOut := &bytes.Buffer{}
    	cw := &ConfigWriter{Stdout: gotOut}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Dec 13 01:08:07 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  2. cmd/erasure_test.go

    	}
    	for i, test := range erasureEncodeDecodeTests {
    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.parityBlocks, blockSizeV2)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create erasure: %v", i, err)
    		}
    		encoded, err := erasure.EncodeData(context.Background(), buffer)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  3. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

            }
        }
    
        private void parseHtmlEntity(StringBuilder buffer) {
            scanner.next();
            scanner.mark();
            scanner.find(';');
            String value = ENTITIES.get(scanner.region().toLowerCase(Locale.ROOT));
            buffer.append(value);
            scanner.next();
        }
    
        private void parseHtmlEncodedChar(StringBuilder buffer) {
            scanner.next(2);
            scanner.mark();
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/NtTransQuerySecurityDesc.java

        int writeDataWireFormat( byte[] dst, int dstIndex ) {
            return 0;
        }
        int readSetupWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        int readParametersWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        int readDataWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        public String toString() {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.5K bytes
    - Viewed (0)
  5. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

    import java.io.IOException
    import okio.BufferedSource
    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() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. internal/http/response-recorder.go

    	ttfbBody   time.Duration
    
    	StartTime time.Time
    	// number of bytes written
    	bytesWritten int
    	// number of bytes of response headers written
    	headerBytesWritten int
    	// Internal recording buffer
    	headers bytes.Buffer
    	body    bytes.Buffer
    	// Indicate if headers are written in the log
    	headersLogged bool
    }
    
    // Hijack - hijacks the underlying connection
    func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/NetShareEnum.java

        int writeDataWireFormat( byte[] dst, int dstIndex ) {
            return 0;
        }
        int readSetupWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        int readParametersWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        int readDataWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        public String toString() {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.5K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt

     * limitations under the License.
     */
    package okhttp3
    
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import java.net.InetAddress
    import java.net.UnknownHostException
    import okio.Buffer
    
    class FakeDns : Dns {
      private val hostAddresses: MutableMap<String, List<InetAddress>> = mutableMapOf()
      private val requestedHosts: MutableList<String> = mutableListOf()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.cache2
    
    import java.io.IOException
    import java.nio.channels.FileChannel
    import okio.Buffer
    
    /**
     * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)`
     * this class offers:
     *
     *  * **Read/write:** read and write using the same operator.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. src/bufio/example_test.go

    		return
    	}
    
    	if err = writer.Flush(); err != nil {
    		fmt.Println("Flush Error:", err)
    		return
    	}
    
    	fmt.Println("Bytes written:", n)
    	fmt.Println("Buffer contents:", buf.String())
    	// Output:
    	// Bytes written: 41
    	// Buffer contents: Hello, world!
    	// This is a ReadFrom example.
    }
    
    // The simplest use of a Scanner, to read standard input as a set of lines.
    func ExampleScanner_lines() {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top