graph, graphql: Remove Resolver.resolve_field_stream and UnitStream

graphprotocol · Feb 18, 2025 · 9c69088 · 9c69088
1 parent d520d88
commit 9c69088
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 15 deletions.
diff --git a/graph/src/components/store/mod.rs b/graph/src/components/store/mod.rs
@@ -628,8 +628,6 @@ pub struct StoreEventStream<S> {
 pub type StoreEventStreamBox =
     StoreEventStream<Box<dyn Stream<Item = Arc<StoreEvent>, Error = ()> + Send>>;
 
-pub type UnitStream = Box<dyn futures03::Stream<Item = ()> + Unpin + Send + Sync>;
-
 impl<S> Stream for StoreEventStream<S>
 where
     S: Stream<Item = Arc<StoreEvent>, Error = ()> + Send,

diff --git a/graphql/src/execution/resolver.rs b/graphql/src/execution/resolver.rs
@@ -1,6 +1,6 @@
 use std::time::Duration;
 
-use graph::components::store::{QueryPermit, UnitStream};
+use graph::components::store::QueryPermit;
 use graph::data::query::{CacheStatus, Trace};
 use graph::prelude::{async_trait, s, Error, QueryExecutionError};
 use graph::schema::ApiSchema;
@@ -111,18 +111,6 @@ pub trait Resolver: Sized + Send + Sync + 'static {
         }
     }
 
-    // Resolves a change stream for a given field.
-    fn resolve_field_stream(
-        &self,
-        _schema: &ApiSchema,
-        _object_type: &s::ObjectType,
-        _field: &a::Field,
-    ) -> Result<UnitStream, QueryExecutionError> {
-        Err(QueryExecutionError::NotSupported(String::from(
-            "Resolving field streams is not supported by this resolver",
-        )))
-    }
-
     fn post_process(&self, _result: &mut QueryResult) -> Result<(), Error> {
         Ok(())
     }