written - Code Search

internal/grid/connection.go

		block := (<-chan struct{})(a)
		c.blockMessages.Store(&block)
		c.connMu.Unlock()
	}
}

// wsWriter writes websocket messages.
type wsWriter struct {
	tmp [ws.MaxHeaderSize]byte
}

// writeMessage writes a message to w without allocations.
func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error {
	const fin = true
	var frame ws.Frame
	if s.ClientSide() {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 46.9K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic-commons/code-quality-rules/src/main/resources/classycle/classycle_report_resources.zip

s,width=500,height=400"); list.document.close(); list.document.open(); list.document.write("<html><head><style type=\"text/css\">"); list.document.write("body { font-family:Helvetica,Arial,sans-serif; } "); list.document.write(".link { cursor:pointer;text-decoration:underline; } "); list.document.writeln("th { background-color:#aaaaaa; } </style></head><body>"); list.document.writeln(text); list.document.writeln("</body></html>"); list.document.close(); list.focus(); } //--> Analysis of Date: Summary...

Registered: Wed Dec 31 11:36:14 UTC 2025

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 23.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

                                writer.write(hit.getSourceAsString());
                                writer.write("\n");
                            } catch (final IOException e) {
                                throw new IORuntimeException(e);
                            }
                            return true;
                        });
                        writer.flush();
                    }

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Mon Nov 24 02:07:40 UTC 2025

- 32.1K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/AcceptedApiChangesJsonFileManager.groovy

    void emptyAcceptedApiChanges(File jsonFile) {
        jsonFile.withWriter { fileWriter ->
            def writer = new JsonWriter(fileWriter)
            writer.setIndent("    ")
            new Gson().toJson([acceptedApiChanges: []], Object, writer)
            writer.close()
        }
    }

Registered: Wed Dec 31 11:36:14 UTC 2025

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/CharSinkTest.java

  public void setUp() {
    sink = new TestCharSink();
  }

  public void testOpenBufferedStream() throws IOException {
    Writer writer = sink.openBufferedStream();
    assertTrue(sink.wasStreamOpened());
    assertFalse(sink.wasStreamClosed());

    writer.write(STRING);
    writer.close();

    assertTrue(sink.wasStreamClosed());
    assertEquals(STRING, sink.getString());
  }

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Thu Dec 19 18:03:30 UTC 2024

- 4.6K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/CharStreamsTest.java

  }

  public void testNullWriter() throws Exception {
    // create a null writer
    Writer nullWriter = CharStreams.nullWriter();
    // write to the writer
    nullWriter.write('n');
    String test = "Test string for NullWriter";
    nullWriter.write(test);
    nullWriter.write(test, 2, 10);
    nullWriter.append(null);
    nullWriter.append(null, 0, 4);

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Oct 28 16:03:47 UTC 2025

- 11.3K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/io/CharStreamsTest.java

  }

  public void testNullWriter() throws Exception {
    // create a null writer
    Writer nullWriter = CharStreams.nullWriter();
    // write to the writer
    nullWriter.write('n');
    String test = "Test string for NullWriter";
    nullWriter.write(test);
    nullWriter.write(test, 2, 10);
    nullWriter.append(null);
    nullWriter.append(null, 0, 4);

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Oct 28 16:03:47 UTC 2025

- 11.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool-rebalance_gen.go

func (z rebalanceInfo) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 3
	// write "startTs"
	err = en.Append(0x83, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x73)
	if err != nil {
		return
	}
	err = en.WriteTime(z.StartTime)
	if err != nil {
		err = msgp.WrapError(err, "StartTime")
		return
	}
	// write "stopTs"
	err = en.Append(0xa6, 0x73, 0x74, 0x6f, 0x70, 0x54, 0x73)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 26.8K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/DefaultToolchainsWriter.java

    @Override
    public void write(Writer output, Map<String, Object> options, PersistedToolchains toolchains) throws IOException {
        Objects.requireNonNull(output, "output cannot be null");
        Objects.requireNonNull(toolchains, "toolchains cannot be null");

        try (Writer out = output) {
            new MavenToolchainsStaxWriter().write(out, toolchains.getDelegate());

Registered: Sun Dec 28 03:35:09 UTC 2025

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

- 1.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/local-locker_gen.go

		return
	}
	err = en.WriteBool(z.Writer)
	if err != nil {
		err = msgp.WrapError(err, "Writer")
		return
	}
	// write "UID"
	err = en.Append(0xa3, 0x55, 0x49, 0x44)
	if err != nil {
		return
	}
	err = en.WriteString(z.UID)
	if err != nil {
		err = msgp.WrapError(err, "UID")
		return
	}
	// write "Timestamp"
	err = en.Append(0xa9, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70)
	if err != nil {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 16.6K bytes

- Viewed (0)

Search Options