added streaming example

Author: jell-o-fishi

examples/graphql/client_graphql.py

@@ -2,16 +2,12 @@
 import logging
 import sys
 
-import aiohttp
 from gql import gql, Client
 
-from rsocket.extensions.helpers import route, composite
 from rsocket.extensions.mimetypes import WellKnownMimeTypes
 from rsocket.graphql.rsocket_transport import RSocketTransport
 from rsocket.helpers import single_transport_provider
-from rsocket.payload import Payload
 from rsocket.rsocket_client import RSocketClient
-from rsocket.transports.aiohttp_websocket import TransportAioHttpClient
 from rsocket.transports.tcp import TransportTCP
 
 
@@ -33,48 +29,22 @@ async def main(server_port: int):
             transport=RSocketTransport(client),
         )
 
-        # response = await client.request_response(Payload(metadata=composite(route('ping'))))
-        #
-        # assert response.data == b'pong'
-
         await greeting(graphql)
 
-        # await echo(graphql)
-
-        # await subscription(graphql)
+        await subscription(graphql)
 
 
 async def subscription(graphql: Client):
     async for response in graphql.subscribe_async(
             document=gql("""
-                subscription multipleGreetings {
-                    multipleGreetings
+                subscription {
+                    greetings {message}
                 }
                 """),
             get_execution_result=True):
         print(response.data)
 
 
-async def echo(graphql: Client):
-    message = 'and now for something completely different'
-
-    response = await graphql.execute_async(
-        document=gql("""
-                query echo($input: String) {
-                    echo(input: $input) {
-                      message
-                    }
-                  }
-                """),
-        variable_values={'input': message},
-        get_execution_result=True
-    )
-
-    assert response.data['echo']['message'] == message
-
-    print(response.data)
-
-
 async def greeting(graphql: Client):
     response = await graphql.execute_async(
         gql("""query { greeting { message } }"""),

examples/graphql/java/src/main/java/com/example/demo/DemoApplication.java

@@ -3,26 +3,46 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.graphql.data.method.annotation.QueryMapping;
+import org.springframework.graphql.data.method.annotation.SubscriptionMapping;
 import org.springframework.stereotype.Controller;
+import reactor.core.publisher.Flux;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.function.Supplier;
+import java.util.stream.Stream;
 
 @SpringBootApplication
 public class DemoApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(DemoApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(DemoApplication.class, args);
+    }
 
 }
 
 
 @Controller
 class GreetingsController {
-	@QueryMapping
-	Greeting greeting() {
-		return new Greeting("Hello world");
-	}
+    @SubscriptionMapping
+    Flux<Greeting> greetings() {
+        return Flux.fromStream(Stream.generate(
+                        new Supplier<Greeting>() {
+                            @Override
+                            public Greeting get() {
+                                return new Greeting("Hello world @" + Instant.now() + "!");
+                            }
+                        }
+                )).delayElements(Duration.ofSeconds(1))
+                .take(10);
+    }
+
+    @QueryMapping
+    Greeting greeting() {
+        return new Greeting("Hello world");
+    }
 }
 
-record Greeting (String message) {
+record Greeting(String message) {
 
 }

examples/graphql/java/src/main/resources/graphql/rsocket.graphqls

@@ -2,6 +2,10 @@ type Query {
     greeting: Greeting
 }
 
+type Subscription {
+    greetings: Greeting
+}
+
 type Greeting {
     message: String
 }