- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,218 for close (0.17 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
/** * Half close connection (InputStream for client) after reading the request but before * writing the response. Use this to simulate late connection pool failures. */ object HalfCloseAfterRequest : SocketPolicy /** Close connection after reading half of the request body (if present). */ object DisconnectDuringRequestBody : SocketPolicy
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/lock/lock_test.go
} // Decrease reference count by 1. if err = rlk.Close(); err != nil { t.Fatal(err) } isClosed = rlk.IsClosed() if isClosed { t.Fatal("File ref count shouldn't be zero") } // Decrease reference count by 1. if err = rlk.Close(); err != nil { t.Fatal(err) } // Now file should be closed. isClosed = rlk.IsClosed() if !isClosed {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.6K bytes - Viewed (0) -
.github/workflows/invalid_question.yml
name: "Close invalid questions issues" on: schedule: - cron: "*/10 * * * *" permissions: contents: read jobs: stale: permissions: issues: write # for actions/stale to close stale issues pull-requests: write # for actions/stale to close stale PRs runs-on: ubuntu-latest env: ACTIONS_STEP_DEBUG: true steps: - name: Close Stale Issues uses: actions/stale@v8 with:
Others - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Apr 11 02:27:05 GMT 2023 - 1.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/AppendableWriterTest.java
writer.write("Hi"); writer.close(); assertThrows(IOException.class, () -> writer.write(" Greg")); assertThrows(IOException.class, () -> writer.flush()); // close()ing already closed writer is allowed writer.close(); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
maskCursor.close() } } when (opcode) { OPCODE_CONTROL_PING -> { frameCallback.onReadPing(controlFrameBuffer.readByteString()) } OPCODE_CONTROL_PONG -> { frameCallback.onReadPong(controlFrameBuffer.readByteString()) } OPCODE_CONTROL_CLOSE -> { var code = CLOSE_NO_STATUS_CODE var reason = ""
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// we find them, regardless of what the address policies need. // // 2. EVICTABLE: Connections not required by any address policy. This matches connections that // don't participate in any policy, plus connections whose policies won't be violated if the // connection is closed. We only close these if the idle connection limit is exceeded. //
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
cmd/metacache-stream.go
continue } } }() return objs, nil } // Close and release resources. func (w *metacacheWriter) Close() error { if w == nil || w.closer == nil { return nil } w.streamWg.Wait() err := w.closer() w.closer = nil return err } // Reset and start writing to new writer. // Close must have been called before this. func (w *metacacheWriter) Reset(out io.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) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* This method returns true if the message was enqueued. Messages that would overflow the outgoing * message buffer will be rejected and trigger a [graceful shutdown][close] of this web socket. * This method returns false in that case, and in any other case where this web socket is closing, * closed, or canceled. * * This method returns immediately. */ fun send(text: String): Boolean /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
) var response = call.execute() assertThat(response.code).isEqualTo(200) response.close() listener.clearAllEvents() call = call.clone() response = call.execute() assertThat(response.code).isEqualTo(200) assertThat(response.body.string()).isEqualTo("abc") response.close() assertThat(listener.recordedEventTypes()).containsExactly( "CallStart", "CacheConditionalHit",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
) { check(!closed) { "closed" } checkOffsetAndCount(source.size, 0, byteCount) sink.write(source, byteCount) } override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. sink.flush() } override fun close() { if (closed) return closed = true detachTimeout(timeout)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0)