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

use FnOnce for callback function

Browse source
This commit is contained in:
yggverse 2025-01-17 07:32:09 +02:00
parent c67593e5fd
commit 61fbab6dae
2 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/client.rs
View file

@ -60,7 +60,7 @@ impl Client {
priority: Priority, priority: Priority,
cancellable: Cancellable, cancellable: Cancellable,
certificate: Option<TlsCertificate>, certificate: Option<TlsCertificate>,
callback: impl Fn(Result<Response, Error>) + 'static, callback: impl FnOnce(Result<Response, Error>) + 'static,
) { ) {
// Begin new connection // Begin new connection
// * [NetworkAddress](https://docs.gtk.org/gio/class.NetworkAddress.html) required for valid // * [NetworkAddress](https://docs.gtk.org/gio/class.NetworkAddress.html) required for valid

8
src/client/connection.rs
View file

@ -56,7 +56,7 @@ impl Connection {
request: Request, request: Request,
priority: Priority, priority: Priority,
cancellable: Cancellable, cancellable: Cancellable,
callback: impl Fn(Result<Response, Error>) + 'static, callback: impl FnOnce(Result<Response, Error>) + 'static,
) { ) {
match request { match request {
Request::Gemini(request) => { Request::Gemini(request) => {
@ -77,7 +77,7 @@ impl Connection {
request: Gemini, request: Gemini,
priority: Priority, priority: Priority,
cancellable: Cancellable, cancellable: Cancellable,
callback: impl Fn(Result<Response, Error>) + 'static, 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);
} }
@ -91,7 +91,7 @@ impl Connection {
request: Titan, request: Titan,
priority: Priority, priority: Priority,
cancellable: Cancellable, cancellable: Cancellable,
callback: impl Fn(Result<Response, Error>) + 'static, 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);
} }
@ -107,7 +107,7 @@ impl Connection {
request: &Bytes, request: &Bytes,
priority: Priority, priority: Priority,
cancellable: Cancellable, cancellable: Cancellable,
callback: impl Fn(Result<Response, Error>) + 'static, callback: impl FnOnce(Result<Response, Error>) + 'static,
) { ) {
self.stream().output_stream().write_bytes_async( self.stream().output_stream().write_bytes_async(
request, request,