street - Code Search

internal/logger/console.go

		} else {
			msg = "a fatal error"
		}
	} else {
		msg = fmt.Sprintf(msg, data...)
	}
	consoleLog(fatalMessage, errorFmtFunc(msg, err, jsonFlag))
}

var fatalMessage fatalMsg

type fatalMsg struct{}

func (f fatalMsg) json(msg string, args ...interface{}) {
	var message string
	if msg != "" {
		message = fmt.Sprintf(msg, args...)
	} else {
		message = fmt.Sprint(args...)
	}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Jul 12 20:51:54 UTC 2024

- 7.5K bytes

- Viewed (0)

github.com/tiangolo/fastapi

fastapi/openapi/docs.py

    html = """
    <!doctype html>
    <html lang="en-US">
    <head>
        <title>Swagger UI: OAuth2 Redirect</title>
    </head>
    <body>
    <script>
        'use strict';
        function run () {
            var oauth2 = window.opener.swaggerUIRedirectOauth2;
            var sentState = oauth2.state;
            var redirectUrl = oauth2.redirectUrl;
            var isValid, qp, arr;

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu May 23 22:59:02 UTC 2024

- 10.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

        if (StringUtil.isNotEmpty(contentType)) {
            curlRequest.header("Content-Type", contentType);
        }

        request.getParameterMap().entrySet().stream().forEach(entry -> {
            if (entry.getValue().length > 1) {
                curlRequest.param(entry.getKey(), String.join(",", entry.getValue()));
            } else if (entry.getValue().length == 1) {

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Aug 15 08:29:24 UTC 2024

- 11.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb1/SMB1SigningDigest.java

        update(sequence, 0, sequence.length);
        index += 8;
        if ( msg.getCommand() == ServerMessageBlock.SMB_COM_READ_ANDX ) {
            /*
             * SmbComReadAndXResponse reads directly from the stream into separate byte[] b.
             */
            SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) msg;
            int length = msg.getLength() - raxr.getDataLength();

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun Aug 05 09:45:59 UTC 2018

- 10.6K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/ImmutableListMultimapTest.java

import com.google.common.testing.SerializableTester;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.Map.Entry;
import java.util.function.BiPredicate;
import java.util.stream.Collector;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
import org.checkerframework.checker.nullness.qual.Nullable;

/**
 * Tests for {@link ImmutableListMultimap}.

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Oct 30 16:15:19 UTC 2024

- 25.4K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/c_api.cc

    // TODO(skyewm): prefix names with underscore (requires some plumbing)
    if (!CreateInput(inputs[i], cond_graph, StrCat("cond_input", i).c_str(),
                     &cond_inputs[i], status)) {
      break;
    }
    if (!CreateInput(inputs[i], body_graph, StrCat("body_input", i).c_str(),
                     &body_inputs[i], status)) {
      break;
    }
  }

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Sat Oct 12 16:27:48 UTC 2024

- 102.3K bytes

- Viewed (0)

github.com/minio/minio

docs/bucket/lifecycle/README.md

```
mc admin tier add s3 source S3TIER --bucket s3bucket --prefix testprefix/ --use-aws-role
```

Once transitioned, GET or HEAD on the object will stream the content from the transitioned tier. In the event that the object needs to be restored temporarily to the local cluster, the AWS [RestoreObject API](https://docs.aws.amazon.com/AmazonS3/latest/API/API_RestoreObject.html) can be utilized.

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Jul 09 01:45:38 UTC 2024

- 9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

    }

    private fun bodyIsStreaming(response: Response): Boolean {
      val contentType = response.body.contentType()
      return contentType != null && contentType.type == "text" && contentType.subtype == "event-stream"
    }

    companion object

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Apr 06 09:14:38 UTC 2024

- 11.2K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

"          frameborder=\"0\" allow=\"accelerometer; autoplay; clipboard-write; encrypted-media; gyroscope; picture-in-picture; web-share\" \n" +
"          referrerpolicy=\"strict-origin-when-cross-origin\" allowfullscreen> \n" +
"        </iframe> \n" +
"    </div> \n" +
"  </div> \n" +
"</details>");

        // Same for the Wistia-hosted videos

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Thu Oct 03 05:02:20 UTC 2024

- 9.9K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java

 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.project.interpolation;

import javax.inject.Inject;
import javax.xml.stream.XMLStreamException;

import java.io.File;
import java.io.IOException;
import java.io.StringReader;
import java.io.StringWriter;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 13.5K bytes

- Viewed (0)

Search Options