- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 245 for isopen (0.24 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream. * * Both input and output streams have transmitted all data and headers. * * Note that the input stream may continue to yield data even after a stream reports itself as * not open. This is because input data is buffered. */ val isOpen: Boolean get() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} else { writePing(false, INTERVAL_PING, 0) return@schedule pingIntervalNanos } } } } /** * Returns the number of [open streams][Http2Stream.isOpen] on this connection. */ fun openStreamCount(): Int = this.withLock { streams.size } fun getStream(id: Int): Http2Stream? = this.withLock { streams[id] }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
} sink1.writeUtf8("def") sink1.close() assertFailsWith<ConnectionShutdownException> { connection.newStream(headerEntries("c", "cola"), true) } assertThat(stream1.isOpen).isTrue() assertThat(stream2.isOpen).isFalse() assertThat(connection.openStreamCount()).isEqualTo(1) // Verify the peer received what was expected. val synStream1 = peer.takeFrame()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
internal/ioutil/read_file.go
"io" "io/fs" "os" "github.com/minio/minio/internal/disk" ) var ( // OpenFileDirectIO allows overriding default function. OpenFileDirectIO = disk.OpenFileDirectIO // OsOpen allows overriding default function. OsOpen = os.Open // OsOpenFile allows overriding default function. OsOpenFile = os.OpenFile ) // ReadFileWithFileInfo reads the named file and returns the contents.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
private val events = LinkedBlockingDeque<Any>() private var cancel = false fun enqueueCancel() { cancel = true } override fun onOpen( eventSource: EventSource, response: Response, ) { get().log("[ES] onOpen", Platform.INFO, null) events.add(Open(eventSource, response)) drainCancelQueue(eventSource) } override fun onEvent( eventSource: EventSource, id: String?,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt
* messages. */ open fun onOpen( webSocket: WebSocket, response: Response, ) { } /** Invoked when a text (type `0x1`) message has been received. */ open fun onMessage( webSocket: WebSocket, text: String, ) { } /** Invoked when a binary (type `0x2`) message has been received. */ open fun onMessage( webSocket: WebSocket,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp-sse/api/okhttp-sse.api
public fun onEvent (Lokhttp3/sse/EventSource;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V public fun onFailure (Lokhttp3/sse/EventSource;Ljava/lang/Throwable;Lokhttp3/Response;)V public fun onOpen (Lokhttp3/sse/EventSource;Lokhttp3/Response;)V } public final class okhttp3/sse/EventSources { public static final field INSTANCE Lokhttp3/sse/EventSources;
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Dec 17 14:39:59 GMT 2023 - 1.1K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
/** * Invoked when an event source has been accepted by the remote peer and may begin transmitting * events. */ open fun onOpen( eventSource: EventSource, response: Response, ) { } /** * TODO description. */ open fun onEvent( eventSource: EventSource, id: String?, type: String?, data: String, ) { } /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (1) -
cmd/os-instrumented.go
// os.Lstat() func Access(name string) (err error) { defer updateOSMetrics(osMetricAccess, name)(err) return access(name) } // Open captures time taken to call os.Open func Open(name string) (f *os.File, err error) { defer updateOSMetrics(osMetricOpen, name)(err) return os.Open(name) } // OpenFileDirectIO captures time taken to call disk.OpenFileDirectIO
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
this.delegate = delegate } override fun onOpen( webSocket: WebSocket, response: Response, ) { Platform.get().log("[WS $name] onOpen", Platform.INFO, null) val delegate = delegate if (delegate != null) { this.delegate = null delegate.onOpen(webSocket, response) } else { events.add(Open(webSocket, response)) } } override fun onMessage(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0)