Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 511 for seni (0.02 sec)

  1. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        taskFaker.runTasks()
        assertThat(client.closed).isTrue()
        server.listener.assertExhausted() // Client should not have sent second close.
        client.listener.assertExhausted() // Server should not have sent second close.
      }
    
      @Test
      fun serverCloseBreaksReadMessageLoop() {
        server.webSocket!!.send("Hello!")
        server.webSocket!!.close(1000, "Bye!")
        assertThat(client.processNextFrame()).isTrue()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. fastapi/security/api_key.py

        with the API key and integrates that into the OpenAPI documentation. It extracts
        the key value sent in the query parameter automatically and provides it as the
        dependency result. But it doesn't define how to send that API key to the client.
    
        ## Usage
    
        Create an instance object and use that object as the dependency in `Depends()`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 23 22:29:18 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. internal/grid/muxserver.go

    			if debugPrint {
    				fmt.Println("muxServer: Mux", m.ID, "send EOF", hErr)
    			}
    			msg.Flags |= FlagEOF
    			if hErr != nil {
    				msg.Flags |= FlagPayloadIsErr
    				msg.Payload = []byte(*hErr)
    			}
    			msg.setZeroPayloadFlag()
    			m.send(msg)
    			return
    		}
    		msg.Payload = payload
    		msg.setZeroPayloadFlag()
    		m.send(msg)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/NotificationHelper.java

                            logger.debug("Sent {} to {}.", body, url);
                        }
                    } else {
                        logger.warn("Failed to send {} to {}. HTTP Status is {}. {}", body, url, response.getHttpStatusCode(),
                                response.getContentAsString());
                    }
                } catch (final IOException e) {
                    logger.warn("Failed to send {} to {}.", body, url, e);
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      }
    
      // Writer methods to enqueue frames. They'll be sent asynchronously by the writer thread.
    
      override fun send(text: String): Boolean {
        return send(text.encodeUtf8(), OPCODE_TEXT)
      }
    
      override fun send(bytes: ByteString): Boolean {
        return send(bytes, OPCODE_BINARY)
      }
    
      @Synchronized private fun send(
        data: ByteString,
        formatOpcode: Int,
      ): Boolean {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  6. docs_src/background_tasks/tutorial002.py

            background_tasks.add_task(write_log, message)
        return q
    
    
    @app.post("/send-notification/{email}")
    async def send_notification(
        email: str, background_tasks: BackgroundTasks, q: str = Depends(get_query)
    ):
        message = f"message to {email}\n"
        background_tasks.add_task(write_log, message)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat May 14 11:59:59 UTC 2022
    - 675 bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

       * closing, closed, or canceled.
       *
       * This method returns immediately.
       */
      fun send(bytes: ByteString): Boolean
    
      /**
       * Attempts to initiate a graceful shutdown of this web socket. Any already-enqueued messages will
       * be transmitted before the close message is sent but subsequent calls to [send] will return
       * false and their messages will not be enqueued.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

            flags = FLAG_ACK,
          )
          sink.flush()
        }
      }
    
      /**
       * HTTP/2 only. Send a push promise header block.
       *
       * A push promise contains all the headers that pertain to a server-initiated request, and a
       * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as
       * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. internal/event/target/mqtt.go

    		return err
    	}
    
    	// Do not send if the connection is not active.
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. internal/grid/stream.go

    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    	// Requests sent cannot be used any further by the called.
    	Requests chan<- []byte
    
    	muxID uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top