- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,063 for received (0.17 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val connection = connect(peer) connection.writePingAndAwaitPong() // Ensure the SETTINGS have been received. val stream = connection.newStream(headerEntries("a", "android"), true) val sink = stream.getSink().buffer() sink.writeUtf8("abcdefghi") sink.flush() // Verify the peer received what was expected. peer.takeFrame() // PING val headers = peer.takeFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
var writeBytesMaximum: Long = connection.peerSettings.initialWindowSize.toLong() internal set /** Received headers yet to be [taken][takeHeaders]. */ private val headersQueue = ArrayDeque<Headers>() /** True if response headers have been sent or received. */ private var hasResponseHeaders: Boolean = false internal val source = FramingSource(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
internal/grid/errors.go
ErrHandlerAlreadyExists = errors.New("mux handler already exists") // ErrIncorrectSequence is returned when an out-of-sequence item is received. ErrIncorrectSequence = errors.New("out-of-sequence item received") ) // ErrResponse is a remote error response. type ErrResponse struct { msg string } func (e ErrResponse) Error() string { return fmt.Sprintf("remote: %s", e.msg)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 1.4K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_node_if_rx_bytes` | Bytes received on the interface in 60s. | | `minio_node_if_rx_bytes_avg` | Bytes received on the interface in 60s (avg) since uptime. | | `minio_node_if_rx_bytes_max` | Bytes received on the interface in 60s (max) since uptime. | | `minio_node_if_rx_errors` | Receive errors in 60s. |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
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. * * This does nothing if [requestBody] and [responseBody] are already closed. *
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) -
fastapi/dependencies/utils.py
required_params: Sequence[ModelField], received_params: Union[Mapping[str, Any], QueryParams, Headers], ) -> Tuple[Dict[str, Any], List[Any]]: values = {} errors = [] for field in required_params: if is_scalar_sequence_field(field) and isinstance( received_params, (QueryParams, Headers) ): value = received_params.getlist(field.alias) or field.default else:
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 02:52:56 GMT 2024 - 29.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
response: Response, ) { } /** * Invoked when a result is served from the cache. The Response provided is the top level * Response and normal event sequences will not be received. * * This event will only be received when a Cache is configured for the client. */ open fun cacheHit( call: Call, response: Response, ) { } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
cmd/metrics.go
prometheus.NewDesc( prometheus.BuildFQName(interNodeNamespace, "rx", "bytes_total"), "Total number of internode bytes received by current MinIO server instance", nil, nil), prometheus.CounterValue, float64(connStats.internodeInputBytes), ) // Network Sent/Received Bytes (Outbound) ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(s3Namespace, "tx", "bytes_total"),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/crossdomain-xml-handler_test.go
// but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "net/http" "net/http/httptest" "testing"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jul 08 14:31:42 GMT 2023 - 1.3K bytes - Viewed (0) -
internal/http/transports.go
// // frame will be carried out if no frame is received on the // // connection. 5 minutes is sufficient time for any idle connection. // trhttp2.ReadIdleTimeout = 5 * time.Minute // // PingTimeout is the timeout after which the connection will be closed // // if a response to Ping is not received. // trhttp2.PingTimeout = dialTimeout
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0)