- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 742 for received1 (0.1 sec)
-
internal/grid/msg.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 grid import ( "encoding/binary" "fmt" "strings" "time"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jul 25 21:07:21 UTC 2024 - 7.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
*/ @ExperimentalOkHttpApi interface AsyncDns { /** * Query DNS records for `hostname`, in the order they are received. */ fun query( hostname: String, callback: Callback, ) /** * Callback to receive results from the DNS Queries. */ @ExperimentalOkHttpApi interface Callback { /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3.5K 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(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
docs/metrics/prometheus/alerts.md
Prometheus AlertManager is the component that manages sending, inhibition and silencing of the alerts generated from Prometheus. The AlertManager can be configured to send alerts to variety of receivers. Refer [Prometheus AlertManager receivers](https://prometheus.io/docs/alerting/latest/configuration/#receiver) for more details. Follow below steps to enable and use AlertManager. ## Deploy and start AlertManager
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jan 28 20:53:59 UTC 2024 - 4.4K bytes - Viewed (0) -
doc/go1.17_spec.html
</pre> <h3 id="Receive_operator">Receive operator</h3> <p> For an operand <code>ch</code> of <a href="#Channel_types">channel type</a>, the value of the receive operation <code><-ch</code> is the value received from the channel <code>ch</code>. The channel direction must permit receive operations, and the type of the receive operation is the element type of the channel.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 10 18:25:45 UTC 2024 - 211.6K bytes - Viewed (0) -
docs/en/docs/tutorial/encoder.md
Let's imagine that you have a database `fake_db` that only receives JSON compatible data. For example, it doesn't receive `datetime` objects, as those are not compatible with JSON. So, a `datetime` object would have to be converted to a `str` containing the data in <a href="https://en.wikipedia.org/wiki/ISO_8601" class="external-link" target="_blank">ISO format</a>.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 23:31:16 UTC 2024 - 1.6K bytes - Viewed (0) -
internal/pubsub/pubsub.go
maxSubscribers int32 // not atomics: subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
internal/grid/muxserver.go
fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq) } m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false) return false } m.RecvSeq++ return true } func (m *muxServer) message(msg message) { if debugPrint { fmt.Printf("muxServer: received message %d, length %d\n", msg.Seq, len(msg.Payload)) } if !m.checkSeq(msg.Seq) { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
docs/en/docs/advanced/security/oauth2-scopes.md
We are still using the same `OAuth2PasswordRequestForm`. It includes a property `scopes` with a `list` of `str`, with each scope it received in the request. And we return the scopes as part of the JWT token. /// danger For simplicity, here we are just adding the scopes received directly to the token.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Oct 29 11:02:16 UTC 2024 - 13.1K bytes - Viewed (0) -
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()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0)