kitkars

@mrniko This is a feature request. Currently Spring supports only **_Kafka_** and **_RabbitMQ_** for cloud stream applications. There is no support for Redis Stream. https://github.com/spring-cloud/spring-cloud-stream#binder-implementations I think Redisson could implement...

Stream - do not emit empty map

2

@mrniko **Issue:** Below code returns an empty map when there are no messages. Ideally Mono should be emitting an **_empty signal_**. Not an empty map. ``` Mono groupMono = stream.readGroup("testGroup",...

Building query at run time

4

Does spring for graphql provide a way to call another graphql-server by passing the current selection set as a query? For ex: Let's say, there is an external Graphql-Server A...

How to decode Union!

1

spring for graphql works great. I came across this issue & not sure how to decode this with `HttpGraphqlClient` retrieve or execute method. `union Notification = TweetSuggestion | SomeoneLikedYourTweet |...

Do not ignore a DataFetcher with a DataFetcherFactories wrapper

1

**schem.graphqls** ``` directive @UpperCase on FIELD_DEFINITION type Query{ hello: String @UpperCase } ``` **QueryMapping** ``` @QueryMapping public Mono hello(){ return Mono.just("hello"); } ``` **SchemaDirectiveWriting** ``` @Override public GraphQLFieldDefinition onField(SchemaDirectiveWiringEnvironment environment)...

This is a feature request for reactive binder. We could provide transactional support for the following type. ``` @Bean Function transform(){ return outerFlux -> outerFlux .map(innerFlux -> innerFlux.map(...)); } ```...

autoConnect(0) seems to be broken - late subscribers receive data

1

autoConnect(0) seems to be broken completely. **Steps to replicate:** ``` CountDownLatch latch = new CountDownLatch(1); AtomicInteger atomicInteger = new AtomicInteger(0); Flux flux = Flux.generate(sink -> sink.next(atomicInteger.incrementAndGet())) .delayElements(Duration.ofSeconds(1)) .take(7) .cast(Integer.class) .doOnComplete(()...