#[tokio::test] pub async fn test_object() { macro_rules! test_data { ($test_name:ident) => { #[derive(Debug, Clone)] pub struct $test_name { value: i32, } #[async_graphql::Object] impl $test_name { async fn value(&self) -> i32 { self.value } } }; } test_data!(A); } #[tokio::test] pub async fn test_subscription() { macro_rules! test_data { ($test_name:ident) => { #[derive(Debug, Clone)] pub struct $test_name { value: i32, } #[async_graphql::Subscription] impl $test_name { async fn value(&self) -> impl futures_util::stream::Stream + 'static { let value = self.value; futures_util::stream::once(async move { value }) } } }; } test_data!(A); } #[tokio::test] pub async fn test_scalar() { macro_rules! test_data { ($test_name:ident) => { #[derive(Debug, Clone)] pub struct $test_name(i64); #[async_graphql::Scalar] impl async_graphql::ScalarType for $test_name { fn parse(value: async_graphql::Value) -> async_graphql::InputValueResult { match value { async_graphql::Value::Number(n) if n.is_i64() => { Ok($test_name(n.as_i64().unwrap())) } _ => Err(async_graphql::InputValueError::expected_type(value)), } } fn to_value(&self) -> async_graphql::Value { self.0.to_value() } } }; } test_data!(A); }