Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 902 for received1 (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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>&lt;-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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top