0.23 upstream merge fix part 3:

use full power pin-project

Author: ifsheldon

async-openai-wasm/Cargo.toml

@@ -39,7 +39,7 @@ tracing = "0.1"
 derive_builder = "0.20"
 async-convert = "1.0"
 secrecy = { version = "0.8", features = ["serde"] }
-pin-project-lite = "0.2"
+pin-project = "1.1"
 getrandom = { version = "0.2", features = ["js"] }
 bytes = "1.6"
 eventsource-stream = "0.2"

async-openai-wasm/src/client.rs

@@ -6,7 +6,7 @@ use std::task::{Context, Poll};
 use bytes::Bytes;
 use futures::{Stream, stream::StreamExt};
 use futures::stream::Filter;
-use pin_project_lite::pin_project;
+use pin_project::pin_project;
 use reqwest_eventsource::{Event, EventSource, RequestBuilderExt};
 use serde::{de::DeserializeOwned, Serialize};
 
@@ -449,7 +449,7 @@ impl<C: Config> Client<C> {
     ) -> Pin<Box<dyn Stream<Item=Result<O, OpenAIError>> + Send>>
         where
             I: Serialize,
-            O: DeserializeOwned + std::marker::Send + 'static,
+            O: DeserializeOwned + Send + 'static,
     {
         let event_source = self
             .http_client
@@ -487,14 +487,14 @@ impl<C: Config> Client<C> {
     }
 }
 
-pin_project! {
-    /// Request which responds with SSE.
-    /// [server-sent events](https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events#event_stream_format)
-    pub struct OpenAIEventStream<O> {
-        #[pin]
-        stream: Filter<EventSource, future::Ready<bool>, fn(&Result<Event, reqwest_eventsource::Error>) -> future::Ready<bool>>,
-        _phantom_data: PhantomData<O>
-    }
+
+/// Request which responds with SSE.
+/// [server-sent events](https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events#event_stream_format)
+#[pin_project]
+pub struct OpenAIEventStream<O> {
+    #[pin]
+    stream: Filter<EventSource, future::Ready<bool>, fn(&Result<Event, reqwest_eventsource::Error>) -> future::Ready<bool>>,
+    _phantom_data: PhantomData<O>,
 }
 
 impl<O> OpenAIEventStream<O> {