- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for streamTest (0.25 sec)
-
src/encoding/json/stream_test.go
t.Fatalf("decode #%d/%d error: %v", j, i, err) } } if !reflect.DeepEqual(out, streamTest[0:i]) { t.Errorf("decoding %d items: mismatch:", i) for j := range out { if !reflect.DeepEqual(out[j], streamTest[j]) { t.Errorf("#%d:\n\tgot: %v\n\twant: %v", j, out[j], streamTest[j]) } } break } } } func TestDecoderBuffered(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 25 16:00:37 UTC 2023 - 12.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream_test.go
Stephen Kitt <******@****.***> 1683032898 +0200
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 7.4K bytes - Viewed (0) -
tensorflow/cc/experimental/libtf/impl/iostream_test.cc
namespace tf { namespace libtf { namespace impl { TEST(OStreamTest, TestInt64) { Int64 x(42); std::stringstream stream; stream << x; ASSERT_EQ(stream.str(), "42"); } TEST(OStreamTest, TestFloat32) { Float32 x(0.375); // Exactly representable as a float. std::stringstream stream; stream << x; ASSERT_EQ(stream.str(), "0.375"); } TEST(OStreamTest, TestString) { String s("foo");
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 18 09:47:46 UTC 2024 - 2K bytes - Viewed (0) -
cmd/metacache-stream_test.go
Klaus Post <******@****.***> 1663610716 +0200
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
pilot/test/xdstest/grpc.go
} // SlowClientInterceptor is an interceptor that allows injecting delays on Send and Recv func SlowClientInterceptor(recv, send time.Duration) grpc.StreamClientInterceptor { return func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption, ) (grpc.ClientStream, error) { clientStream, err := streamer(ctx, desc, cc, method, opts...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt
assertThat(response.body.string()).isEqualTo("abc") } @Flaky @RetryingTest(5) fun missingClientAuthFailsForNeeds() { // Fails with 11.0.1 https://github.com/square/okhttp/issues/4598 // StreamReset stream was reset: PROT... val client = buildClient(null, clientIntermediateCa.certificate) val socketFactory = buildServerSslSocketFactory() server.useHttps(socketFactory) server.requireClientAuth()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 12.5K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
if size != test.size { t.Errorf("%d expected %d, read %d", i, test.size, size) } if len(test.bytes) != n { t.Errorf("%d did not consume all the bytes", i) } } } var streamTests = []struct { desc string recType recType reqId uint16 content []byte raw []byte }{ {"single record", typeStdout, 1, nil, []byte{1, byte(typeStdout), 0, 1, 0, 0, 0, 0}, },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/test/echo/proto/echo_grpc.pb.go
{ MethodName: "Echo", Handler: _EchoTestService_Echo_Handler, }, { MethodName: "ForwardEcho", Handler: _EchoTestService_ForwardEcho_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "test/echo/proto/echo.proto",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 26 01:14:28 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2/api.pb.go
HandlerType: (*ExampleServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetExampleInfo", Handler: _Example_GetExampleInfo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api.proto", } func (m *ExampleRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 17.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta1/api.pb.go
HandlerType: (*ExampleServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetExampleInfo", Handler: _Example_GetExampleInfo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api.proto", } func (m *ExampleRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 17.3K bytes - Viewed (0)