- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,808 for cyan (0.15 sec)
-
api/maven-api-core/src/main/java/org/apache/maven/api/services/MessageBuilder.java
} /** * Append message content in debug style. * By default, bold cyan * * @param message the message to append * @return the current builder */ @Nonnull default MessageBuilder debug(Object message) { return style(".debug:-bold,f:cyan", message); } /** * Append message content in info style. * By default, bold blue *
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Jan 08 10:37:09 GMT 2024 - 7K bytes - Viewed (0) -
logger/logger.go
// Colors const ( Reset = "\033[0m" Red = "\033[31m" Green = "\033[32m" Yellow = "\033[33m" Blue = "\033[34m" Magenta = "\033[35m" Cyan = "\033[36m" White = "\033[37m" BlueBold = "\033[34;1m" MagentaBold = "\033[35;1m" RedBold = "\033[31;1m" YellowBold = "\033[33;1m" ) // LogLevel log level type LogLevel int
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Tue Nov 07 02:19:41 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/grid/handlers.go
// An optional subroute can be given. Multiple entries are joined with '/'. func (h *StreamTypeHandler[Payload, Req, Resp]) RegisterNoPayload(m *Manager, handle func(ctx context.Context, in <-chan Req, out chan<- Resp) *RemoteErr, subroute ...string) error { h.WithPayload = false return h.register(m, func(ctx context.Context, p Payload, in <-chan Req, out chan<- Resp) *RemoteErr { return handle(ctx, in, out)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
internal/grid/muxserver.go
// Data inbound to the handler var handlerIn chan []byte if inboundCap > 0 { m.inbound = make(chan []byte, inboundCap) handlerIn = make(chan []byte, 1) go func(inbound chan []byte) { wg.Wait() defer xioutil.SafeClose(handlerIn) m.handleInbound(c, inbound, handlerIn) }(m.inbound) } // Fill outbound block. // Each token represents a message that can be sent to the client without blocking.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/service.go
globalServiceFreezeMu.Lock() // Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{} if val := globalServiceFreeze.Swap(_ch); val != nil { if ch, ok := val.(chan struct{}); ok && ch != nil { // Close previous non-nil channel. xioutil.SafeClose(ch) } } globalServiceFreezeCnt = 0 // Don't risk going negative. }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/grid/connection.go
if handler == nil { return nil, ErrUnknownHandler } var requests chan []byte var responses chan Response if handler.InCapacity > 0 { requests = make(chan []byte, handler.InCapacity) } if handler.OutCapacity > 0 { responses = make(chan Response, handler.OutCapacity) } else { responses = make(chan Response, 1) } cl, err := c.newMuxClient(ctx) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) handleTwowayResponses(responseCh chan<- Response, internalResp <-chan Response) { defer m.parent.deleteMux(false, m.MuxID) defer xioutil.SafeClose(responseCh) for resp := range internalResp { responseCh <- resp m.send(message{Op: OpUnblockSrvMux, MuxID: m.MuxID}) } } func (m *muxClient) handleTwowayRequests(internalResp chan<- Response, requests <-chan []byte) { var errState bool if debugPrint {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/README.md
The handler function has this signature. Sample handler: ```go handler := func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr { fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context)) fmt.Println("Subroute:", GetSubroute(ctx)) for { select {
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
t.Fatalf("want %d subscribers, got %d", want, got) } } func TestSubscribeExceedingLimit(t *testing.T) { ps := New[Maskable, Maskable](2) ch1 := make(chan Maskable, 1) ch2 := make(chan Maskable, 1) ch3 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh) if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/storage-rest-server.go
// The returned function should always be called to release resources. // An optional error can be sent which will be picked as text only error, // without its original type by the receiver. // waitForHTTPStream should be used to the receiving side. func streamHTTPResponse(w http.ResponseWriter) *httpStreamResponse { doneCh := make(chan error) blockCh := make(chan []byte) h := httpStreamResponse{done: doneCh, block: blockCh} go func() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0)