- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 370 for iostream (0.19 sec)
-
.github/workflows/gitstream.yml
required: false default: '' jobs: gitStream: timeout-minutes: 15 runs-on: ubuntu-latest name: gitStream workflow automation steps: - name: Evaluate Rules uses: linear-b/gitstream-github-action@v1 env: REPO_READ_TOKEN: ${{ secrets.GITSTREAM_TESTING_TOKEN }} id: rules-engine with:
Others - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Fri Apr 19 12:22:37 GMT 2024 - 1.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Stream.kt
*/ @ExperimentalOkHttpApi interface Stream { val requestBody: BufferedSource val responseBody: BufferedSink /** * Terminate the stream so that no further data is transmitted or received. Note that * [requestBody] may return data after this call; that is the buffered data received before this * stream was canceled. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.3K bytes - Viewed (0) -
cmd/metacache-stream.go
"github.com/tinylib/msgp/msgp" "github.com/valyala/bytebufferpool" ) // metadata stream format: // // The stream is s2 compressed. // https://github.com/klauspost/compress/tree/master/s2#s2-compression // This ensures integrity and reduces the size typically by at least 50%. // // All stream elements are msgpack encoded. // // 1 Integer, metacacheStreamVersion of the writer.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/grid/stream.go
// If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/CollectSpliteratorsTest.java
import com.google.common.base.Ascii; import com.google.common.collect.testing.SpliteratorTester; import java.util.Arrays; import java.util.List; import java.util.Spliterator; import java.util.stream.DoubleStream; import java.util.stream.IntStream; import java.util.stream.LongStream; import junit.framework.TestCase; /** Tests for {@code CollectSpliterators}. */ @GwtCompatible @ElementTypesAreNonnullByDefault
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Feb 19 20:34:55 GMT 2024 - 4K bytes - Viewed (0) -
tensorflow/c/experimental/gradients/nn_grad.cc
absl::Span<AbstractTensorHandle*> grad_inputs) override { /* Given upstream grad U and a BiasAdd: A + bias, the gradients are: * * dA = U * dbias = reduceSum(U, dims = channel_dim) */ AbstractTensorHandle* upstream_grad = grad_outputs[0]; DCHECK(upstream_grad); // Recover data format from forward pass for gradient. std::string data_format;
C++ - Registered: Tue Mar 26 12:39:09 GMT 2024 - Last Modified: Wed Feb 28 13:53:47 GMT 2024 - 5.7K bytes - Viewed (0) -
internal/grid/connection.go
} return true }) if debugReqs { fmt.Println(c.String(), "Disconnected. Clearing outgoing.") } c.outgoing.Clear() c.inStream.Range(func(key uint64, client *muxServer) bool { client.cancel() return true }) c.inStream.Clear() } func (c *Connection) receive(conn net.Conn, r receiver) error { b, op, err := wsutil.ReadData(conn, c.side) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
import okio.Source import okio.Timeout /** * Replicates a single upstream source into multiple downstream sources. Each downstream source * returns the same bytes as the upstream source. Downstream sources may read data either as it * is returned by upstream, or after the upstream source has been exhausted. * * As bytes are returned from upstream they are written to a local file. Downstream sources read * from this file as necessary.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
fun setUp() { file = File(tempDir, "test") } @AfterEach fun tearDown() { executor.shutdown() } @Test fun singleSource() { val upstream = Buffer() upstream.writeUtf8("abcdefghijklm") val relay = edit(file, upstream, metadata, 1024) val source = relay.newSource() val sourceBuffer = Buffer() assertThat(source!!.read(sourceBuffer, 5)).isEqualTo(5)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
if (file.isDirectory) { serveDirectory(stream, file.listFiles()!!) } else if (file.exists()) { serveFile(stream, file) } else { send404(stream, path) } } catch (e: IOException) { Platform.get().log("Failure serving Http2Stream: " + e.message, Platform.INFO, null) } } private fun send404( stream: Http2Stream, path: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K bytes - Viewed (0)