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

remove extra functions

Browse source
This commit is contained in:
yggverse 2025-01-22 10:13:15 +02:00
parent 490a513ddf
commit 52141f3dca
2 changed files with 9 additions and 56 deletions
Download patch file Download diff file Expand all files Collapse all files

30
src/client.rs
View file

@ -78,27 +78,15 @@ impl Client {
Some(network_address), Some(network_address),
is_session_resumption, is_session_resumption,
) { ) {
Ok(connection) => match request { Ok(connection) => connection.request_async(
Request::Gemini(request) => connection request,
.gemini_request_async( priority,
request, cancellable,
priority, move |result| match result {
cancellable, Ok(response) => callback(Ok(response)),
move |result| match result { Err(e) => callback(Err(Error::Connection(e))),
Ok(response) => callback(Ok(response)), },
Err(e) => callback(Err(Error::Connection(e))), ),
},
),
Request::Titan(request) => connection.titan_request_async(
request,
priority,
cancellable,
move |result| match result {
Ok(response) => callback(Ok(response)),
Err(e) => callback(Err(Error::Connection(e))),
},
),
},
Err(e) => callback(Err(Error::Connection(e))), Err(e) => callback(Err(Error::Connection(e))),
} }
} }

35
src/client/connection.rs
View file

@ -57,41 +57,6 @@ impl Connection {
priority: Priority, priority: Priority,
cancellable: Cancellable, cancellable: Cancellable,
callback: impl FnOnce(Result<Response, Error>) + 'static, callback: impl FnOnce(Result<Response, Error>) + 'static,
) {
match request {
Request::Gemini(request) => {
self.gemini_request_async(request, priority, cancellable, callback)
}
Request::Titan(request) => {
self.titan_request_async(request, priority, cancellable, callback)
}
}
}
/// Make new request to `Self` connection using
/// [Gemini](https://geminiprotocol.net/docs/protocol-specification.gmi) protocol
/// * callback with new `Response` on success or `Error` on failure
/// * see also `request_async` method to send multi-protocol requests
pub fn gemini_request_async(
self,
request: Gemini,
priority: Priority,
cancellable: Cancellable,
callback: impl FnOnce(Result<Response, Error>) + 'static,
) {
self.bytes_request_async(&request.to_bytes(), priority, cancellable, callback);
}
/// Make new request to `Self` connection using
/// [Titan](gemini://transjovian.org/titan/page/The%20Titan%20Specification) protocol
/// * callback with new `Response` on success or `Error` on failure
/// * see also `request_async` method to send multi-protocol requests
pub fn titan_request_async(
self,
request: Titan,
priority: Priority,
cancellable: Cancellable,
callback: impl FnOnce(Result<Response, Error>) + 'static,
) { ) {
self.bytes_request_async(&request.to_bytes(), priority, cancellable, callback); self.bytes_request_async(&request.to_bytes(), priority, cancellable, callback);
} }