YGGverse/ggemini
1
0
Fork 0
mirror of https://github.com/YGGverse/ggemini.git synced 2026-03-31 17:15:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

rename entities

Browse source
This commit is contained in:
yggverse 2024-10-28 03:07:12 +02:00
parent b2bceb775a
commit 2a01232f6a
1 changed files with 21 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

29
src/client/response/body.rs
View file

@ -55,7 +55,7 @@ impl Body {
/// Simple way to create `Self` buffer from active [SocketConnection](https://docs.gtk.org/gio/class.SocketConnection.html) /// Simple way to create `Self` buffer from active [SocketConnection](https://docs.gtk.org/gio/class.SocketConnection.html)
/// ///
/// **Options** /// **Options**
/// * `connection` - [SocketConnection](https://docs.gtk.org/gio/class.SocketConnection.html) to read bytes from /// * `socket_connection` - [SocketConnection](https://docs.gtk.org/gio/class.SocketConnection.html) to read bytes from
/// * `callback` function to apply on async operations complete, return `Result<Self, (Error, Option<&str>)>` /// * `callback` function to apply on async operations complete, return `Result<Self, (Error, Option<&str>)>`
/// ///
/// **Notes** /// **Notes**
@ -64,10 +64,17 @@ impl Body {
/// not just [InputStream](https://docs.gtk.org/gio/class.InputStream.html) because of async features; /// not just [InputStream](https://docs.gtk.org/gio/class.InputStream.html) because of async features;
/// * use this method after `Header` bytes taken from input stream connected (otherwise, take a look on high-level `Response` parser) /// * use this method after `Header` bytes taken from input stream connected (otherwise, take a look on high-level `Response` parser)
pub fn from_socket_connection_async( pub fn from_socket_connection_async(
connection: SocketConnection, socket_connection: SocketConnection,
callback: impl FnOnce(Result<Self, (Error, Option<&str>)>) + 'static, callback: impl FnOnce(Result<Self, (Error, Option<&str>)>) + 'static,
) { ) {
Self::read_all_async(Self::new(), connection, None, None, None, callback); Self::read_all_from_socket_connection_async(
Self::new(),
socket_connection,
None,
None,
None,
callback,
);
} }
// Actions // Actions
@ -84,20 +91,20 @@ impl Body {
/// instead of [InputStream](https://docs.gtk.org/gio/class.InputStream.html) just to keep main connection alive in the async chunks context /// instead of [InputStream](https://docs.gtk.org/gio/class.InputStream.html) just to keep main connection alive in the async chunks context
/// ///
/// **Options** /// **Options**
/// * `connection` - [SocketConnection](https://docs.gtk.org/gio/class.SocketConnection.html) to read bytes from /// * `socket_connection` - [SocketConnection](https://docs.gtk.org/gio/class.SocketConnection.html) to read bytes from
/// * `cancellable` - [Cancellable](https://docs.gtk.org/gio/class.Cancellable.html) or `None::<&Cancellable>` by default /// * `cancellable` - [Cancellable](https://docs.gtk.org/gio/class.Cancellable.html) or `None::<&Cancellable>` by default
/// * `priority` - [Priority::DEFAULT](https://docs.gtk.org/glib/const.PRIORITY_DEFAULT.html) by default /// * `priority` - [Priority::DEFAULT](https://docs.gtk.org/glib/const.PRIORITY_DEFAULT.html) by default
/// * `chunk` optional bytes count to read per chunk (`0x100` by default) /// * `chunk` optional bytes count to read per chunk (`0x100` by default)
/// * `callback` function to apply on all async operations complete, return `Result<Self, (Error, Option<&str>)>` /// * `callback` function to apply on all async operations complete, return `Result<Self, (Error, Option<&str>)>`
pub fn read_all_async( pub fn read_all_from_socket_connection_async(
mut self, mut self,
connection: SocketConnection, socket_connection: SocketConnection,
cancelable: Option<Cancellable>, cancelable: Option<Cancellable>,
priority: Option<Priority>, priority: Option<Priority>,
chunk: Option<usize>, chunk: Option<usize>,
callback: impl FnOnce(Result<Self, (Error, Option<&str>)>) + 'static, callback: impl FnOnce(Result<Self, (Error, Option<&str>)>) + 'static,
) { ) {
connection.input_stream().read_bytes_async( socket_connection.input_stream().read_bytes_async(
match chunk { match chunk {
Some(value) => value, Some(value) => value,
None => 0x100, None => 0x100,
@ -124,7 +131,13 @@ impl Body {
}; };
// Continue bytes read.. // Continue bytes read..
self.read_all_async(connection, cancelable, priority, chunk, callback); self.read_all_from_socket_connection_async(
socket_connection,
cancelable,
priority,
chunk,
callback,
);
} }
Err(reason) => callback(Err((Error::InputStreamRead, Some(reason.message())))), Err(reason) => callback(Err((Error::InputStreamRead, Some(reason.message())))),
}, },