Functions — github.com/BonsaiDen/cobalt-rs

CodeHub MCPcopy Create free account

hub / github.com/BonsaiDen/cobalt-rs / functions

Functions196 in github.com/BonsaiDen/cobalt-rs

⨍ Functions 196◇ Types & classes 28

src/test/connection.rs:1029

Tries to create a new UDP socket by binding to the specified address.

src/shared/udp_socket.rs:30

(config: Config)

src/shared/binary_rate_limiter.rs:48

src/shared/noop_packet_modifier.rs:20

Creates a new stats object which averages incoming data over the given number of ticks per second.

src/shared/stats.rs:66

Creates a new Virtual Connection over the given `SocketAddr`. # Examples ``` use std::net::SocketAddr; use cobalt::{ BinaryRateLimiter, Connection,

src/shared/connection.rs:221

Creates a new queue for sending and receiving messages.

src/shared/message_queue.rs:128

(config: Config)

src/shared/ticker.rs:31

src/shared/message_queue.rs:79

Method that is called for payload modification before a packet is send over a connection's underlying socket. The default implementation does not act

src/traits/packet_modifier.rs:28

Methodpartial_cmp

(&self, other: &Self)

src/test/mock_socket.rs:33

Methodpartial_cmp

(&self, other: &Self)

src/shared/message_queue.rs:64

Methodreceive_packet

Parses the contents of a packet into messages, appending all valid messages into the internal receive queue.

src/shared/message_queue.rs:242

Resets the connection for re-use with another address.

src/shared/connection.rs:628

Resets the queue, clearing all its internal structures and order ids.

src/shared/message_queue.rs:270

src/shared/ticker.rs:51

Sends all queued messages over the client's underlying connection. If `auto_tick` is specified as `true` this method will block the current thread fo

src/client.rs:288

Pushes a message of the specified `kind` along with its `data` into the queue. The message will eventually get serialized via `MessageQueue::send_pack

src/shared/message_queue.rs:161

Methodsend_packet

Serializes a number of internally queued messages into the `available` space within the `packet`. The used algorithm first tries to fill the availabl

src/shared/message_queue.rs:206

( &mut self, data: &[u8], addr: SocketAddr )

src/test/mock_socket.rs:70

Methodsent_count

src/test/mock_socket.rs:119

Methodset_config

Overrides the server's current configuration.

src/server.rs:186

Methodset_config

Overrides the client's current configuration.

src/client.rs:181

Methodset_config

Overrides the connection's existing configuration.

src/shared/connection.rs:353

Methodset_config

Overrides the queue's existing configuration.

src/shared/message_queue.rs:143

Methodset_config

(&mut self, config: Config)

src/shared/ticker.rs:41

Returns a mutable reference to the client's underlying socket.

src/client.rs:166

Returns the current state of the connection.

src/shared/connection.rs:321

Functiontest_client_auto_delay_with_load

src/test/client.rs:636

Functiontest_client_close_by_local

src/test/client.rs:556

Functiontest_client_close_by_remote

src/test/client.rs:514

Functiontest_client_configuration

src/test/client.rs:44

Functiontest_client_connect_reset_close

src/test/client.rs:99

Functiontest_client_connection_failure

src/test/client.rs:150

Functiontest_client_connection_ignore_non_peer

src/test/client.rs:262

Functiontest_client_connection_loss_and_reconnect

src/test/client.rs:290

Functiontest_client_connection_success

src/test/client.rs:172

Functiontest_client_disconnected

src/test/client.rs:77

Functiontest_client_flush_auto_delay

src/test/client.rs:620

Functiontest_client_flush_without_delay

src/test/client.rs:135

Functiontest_client_internals

src/test/client.rs:65

Functiontest_client_receive

src/test/client.rs:442

Functiontest_client_reset_events

src/test/client.rs:206

Functiontest_client_send

src/test/client.rs:362

Functiontest_client_without_connection

src/test/client.rs:120

Functiontest_close_local

src/test/connection.rs:110

Functiontest_close_remote

src/test/connection.rs:178

Functiontest_connecting_failed

src/test/connection.rs:215

Functiontest_create

src/test/connection.rs:33

Functiontest_debug_fmt

src/test/connection.rs:52

Functiontest_debug_fmt

src/test/message_queue.rs:16

Functiontest_id_from_packet

src/test/connection.rs:72

Functiontest_in_order_duplicates

src/test/message_queue.rs:455

Functiontest_modes

src/shared/binary_rate_limiter.rs:191

Functiontest_out_of_order_duplicates

src/test/message_queue.rs:474

Functiontest_packet_loss

src/test/connection.rs:908

Functiontest_packet_lost_write

src/test/message_queue.rs:167

Functiontest_packet_modification

src/test/connection.rs:1022

Functiontest_receive_empty

src/test/message_queue.rs:339

Functiontest_receive_invalid

src/test/message_queue.rs:354

Functiontest_receive_invalid_packets

src/test/connection.rs:632

Functiontest_receive_ordered_decoding_wrap_around

src/test/message_queue.rs:384

Functiontest_receive_ordered_encoding_wrap_around

src/test/message_queue.rs:406

Functiontest_receive_packet

src/test/connection.rs:421

Functiontest_receive_packet_ack_overflow

src/test/connection.rs:475

Functiontest_receive_read

src/test/message_queue.rs:216

Functiontest_receive_read_long

src/test/message_queue.rs:245

Functiontest_receive_read_out_of_order

src/test/message_queue.rs:301

Functiontest_reset

src/test/connection.rs:241

Functiontest_reset

src/test/message_queue.rs:431

Functiontest_reset

src/shared/binary_rate_limiter.rs:236

Functiontest_rtt

src/test/connection.rs:704

Functiontest_rtt_tick_correction

src/test/connection.rs:868

Functiontest_send_and_receive_messages

src/test/connection.rs:515

Functiontest_send_and_receive_packet

src/test/connection.rs:301

Functiontest_send_failure

src/test/connection.rs:648

Functiontest_send_sequence_wrap_around

src/test/connection.rs:252

Functiontest_send_write

src/test/message_queue.rs:27

Functiontest_send_write_long

src/test/message_queue.rs:112

Functiontest_server_auto_delay_with_load

src/test/server.rs:689

Functiontest_server_configuration

src/test/server.rs:44

Functiontest_server_connection

src/test/server.rs:147

Functiontest_server_connection_address_remap

src/test/server.rs:217

Functiontest_server_connection_close

src/test/server.rs:539

Functiontest_server_connection_loss

src/test/server.rs:624

Functiontest_server_disconnected

src/test/server.rs:77

Functiontest_server_flow_without_connections

src/test/server.rs:117

Functiontest_server_flush_auto_delay

src/test/server.rs:673

Functiontest_server_flush_without_delay

src/test/server.rs:132

Functiontest_server_internals

src/test/server.rs:65

Functiontest_server_listen_shutdown

src/test/server.rs:100

Functiontest_server_receive

src/test/server.rs:438

Functiontest_server_reset_events

src/test/server.rs:311

Functiontest_server_send

src/test/server.rs:341

Functiontest_set_config

src/test/connection.rs:62

Attempts to return a incoming packet on this socket without blocking.

src/shared/udp_socket.rs:52

← previous101–196 of 196, ranked by callers