- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for keystream (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
override fun writeRequestHeaders(request: Request) { if (stream != null) return val hasRequestBody = request.body != null val requestHeaders = http2HeadersList(request) stream = http2Connection.newStream(requestHeaders, hasRequestBody) // We may have been asked to cancel while creating the new stream and sending the request // headers, but there was still no stream to close. if (canceled) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
platforms/ide/problems-api/src/main/java/org/gradle/internal/problems/DefaultProblemDiagnosticsFactory.java
this.locationAnalyzer = locationAnalyzer; this.userCodeContext = userCodeContext; this.maxStackTraces = maxStackTraces; } @Override public ProblemStream newStream() { return new DefaultProblemStream(); } @Override public ProblemStream newUnlimitedStream() { DefaultProblemStream defaultProblemStream = new DefaultProblemStream();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 08:13:26 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/test/echo/proto/echo_grpc.pb.go
) // EchoTestServiceClient is the client API for EchoTestService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type EchoTestServiceClient interface { Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 26 01:14:28 UTC 2023 - 5.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/LauncherServices.java
return parameter.getWarningMode().shouldDisplayMessages() ? diagnosticsFactory.newUnlimitedStream() : diagnosticsFactory.newStream(); } @Provides BuildTreeActionExecutor createActionExecutor( List<BuildActionRunner> buildActionRunners, StyledTextOutputFactory styledTextOutputFactory,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 13:01:53 UTC 2024 - 12.9K bytes - Viewed (0) -
internal/grid/connection.go
} client.cancelFn(context.Canceled) c.outgoing.Delete(client.MuxID) }() return client.traceRoundtrip(ctx, c.trace, h, req) } // NewStream creates a new stream. // Initial payload can be reused by the caller. func (c *Connection) NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) { if !h.valid() { return nil, ErrUnknownHandler } if c.State() != StateConnected {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/metacache-walk.go
// Ensure remote has the same disk ID. opts.DiskID = *client.diskID.Load() b, err := opts.MarshalMsg(grid.GetByteBuffer()[:0]) if err != nil { return toStorageErr(err) } st, err := client.gridConn.NewStream(ctx, grid.HandlerWalkDir, b) if err != nil { return toStorageErr(err) } return toStorageErr(st.Results(func(in []byte) error { _, err := wr.Write(in) return err })) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/deprecation/LoggingDeprecatedFeatureHandlerTest.groovy
clock::getCurrentTime, currentBuildOperationRef, buildOperationListener) def setup() { _ * diagnosticsFactory.newStream() >> problemStream _ * diagnosticsFactory.newUnlimitedStream() >> problemStream handler.init(WarningMode.All, progressBroadcaster, new DefaultProblems(Stub(ProblemEmitter)), problemStream) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 16:09:54 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2/api.pb.go
// ExampleClient is the client API for Example service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type ExampleClient interface { GetExampleInfo(ctx context.Context, in *ExampleRequest, opts ...grpc.CallOption) (*ExampleResponse, error) } type exampleClient struct { cc *grpc.ClientConn }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 17.3K bytes - Viewed (0) -
internal/config/notify/help.go
Description: "client cert key for NATS mTLS auth", Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{ Key: target.NATSJetStream, Description: "enable JetStream support", Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.NATSQueueDir, Description: queueDirComment, Optional: true, Type: "path",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 19 04:37:54 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta1/api.pb.go
// ExampleClient is the client API for Example service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type ExampleClient interface { GetExampleInfo(ctx context.Context, in *ExampleRequest, opts ...grpc.CallOption) (*ExampleResponse, error) } type exampleClient struct { cc *grpc.ClientConn }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 17.3K bytes - Viewed (0)