diff options
Diffstat (limited to 'ext/fetch')
-rw-r--r-- | ext/fetch/lib.rs | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/ext/fetch/lib.rs b/ext/fetch/lib.rs index 51688a6fc..e41d85ea4 100644 --- a/ext/fetch/lib.rs +++ b/ext/fetch/lib.rs @@ -66,7 +66,7 @@ pub use reqwest; pub use fs_fetch_handler::FsFetchHandler; -use crate::byte_stream::MpscByteStream; +pub use crate::byte_stream::MpscByteStream; #[derive(Clone)] pub struct Options { @@ -186,9 +186,9 @@ pub fn get_declaration() -> PathBuf { #[derive(Serialize)] #[serde(rename_all = "camelCase")] pub struct FetchReturn { - request_rid: ResourceId, - request_body_rid: Option<ResourceId>, - cancel_handle_rid: Option<ResourceId>, + pub request_rid: ResourceId, + pub request_body_rid: Option<ResourceId>, + pub cancel_handle_rid: Option<ResourceId>, } pub fn get_or_create_client_from_state( @@ -302,7 +302,7 @@ where } Some(data) => { // If a body is passed, we use it, and don't return a body for streaming. - request = request.body(Vec::from(&*data)); + request = request.body(data.to_vec()); None } } @@ -400,12 +400,12 @@ where #[derive(Serialize)] #[serde(rename_all = "camelCase")] pub struct FetchResponse { - status: u16, - status_text: String, - headers: Vec<(ByteString, ByteString)>, - url: String, - response_rid: ResourceId, - content_length: Option<u64>, + pub status: u16, + pub status_text: String, + pub headers: Vec<(ByteString, ByteString)>, + pub url: String, + pub response_rid: ResourceId, + pub content_length: Option<u64>, } #[op] @@ -462,8 +462,8 @@ pub async fn op_fetch_send( type CancelableResponseResult = Result<Result<Response, AnyError>, Canceled>; -struct FetchRequestResource( - Pin<Box<dyn Future<Output = CancelableResponseResult>>>, +pub struct FetchRequestResource( + pub Pin<Box<dyn Future<Output = CancelableResponseResult>>>, ); impl Resource for FetchRequestResource { @@ -472,7 +472,7 @@ impl Resource for FetchRequestResource { } } -struct FetchCancelHandle(Rc<CancelHandle>); +pub struct FetchCancelHandle(pub Rc<CancelHandle>); impl Resource for FetchCancelHandle { fn name(&self) -> Cow<str> { @@ -485,8 +485,8 @@ impl Resource for FetchCancelHandle { } pub struct FetchRequestBodyResource { - body: AsyncRefCell<mpsc::Sender<Option<bytes::Bytes>>>, - cancel: CancelHandle, + pub body: AsyncRefCell<mpsc::Sender<Option<bytes::Bytes>>>, + pub cancel: CancelHandle, } impl Resource for FetchRequestBodyResource { @@ -537,10 +537,10 @@ impl Resource for FetchRequestBodyResource { type BytesStream = Pin<Box<dyn Stream<Item = Result<bytes::Bytes, std::io::Error>> + Unpin>>; -struct FetchResponseBodyResource { - reader: AsyncRefCell<Peekable<BytesStream>>, - cancel: CancelHandle, - size: Option<u64>, +pub struct FetchResponseBodyResource { + pub reader: AsyncRefCell<Peekable<BytesStream>>, + pub cancel: CancelHandle, + pub size: Option<u64>, } impl Resource for FetchResponseBodyResource { @@ -590,8 +590,8 @@ impl Resource for FetchResponseBodyResource { } } -struct HttpClientResource { - client: Client, +pub struct HttpClientResource { + pub client: Client, } impl Resource for HttpClientResource { |