@Test void testGetUpdateResponseTypeReturnsTheTypeAsSpecifiedInTheSubscriptionQuery() { ResponseType<String> expectedUpdateResponseType = RESPONSE_TYPE; SubscriptionQueryMessage testSubscriptionQueryMessage = new GenericSubscriptionQueryMessage<>(TEST_QUERY, RESPONSE_TYPE, expectedUpdateResponseType); SubscriptionQuery testSubscriptionQuery = subscriptionMessageSerializer.serialize(testSubscriptionQueryMessage); GrpcBackedSubscriptionQueryMessage<TestQuery, String, String> testSubject = new GrpcBackedSubscriptionQueryMessage<>(testSubscriptionQuery, serializer, serializer); assertEquals( expectedUpdateResponseType.getExpectedResponseType(), testSubject.getResponseType().getExpectedResponseType() ); }
@Override public ResponseType<I> getResponseType() { return grpcBackedQueryMessage.getResponseType(); }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public ResponseType<I> getResponseType() { return grpcBackedQueryMessage.getResponseType(); } }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public ResponseType<I> getResponseType() { return grpcBackedQueryMessage.getResponseType(); } GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                              Serializer messageSerializer,
                                              Serializer serializer); private  GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                               GrpcBackedQueryMessage<Q, I> grpcBackedQueryMessage,
                                               LazyDeserializingObject<ResponseType<U>> serializedUpdateResponseType); }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public ResponseType<I> getResponseType() { return grpcBackedQueryMessage.getResponseType(); } GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                              Serializer messageSerializer,
                                              Serializer serializer); private  GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                               GrpcBackedQueryMessage<Q, I> grpcBackedQueryMessage,
                                               LazyDeserializingObject<ResponseType<U>> serializedUpdateResponseType); @Override ResponseType<U> getUpdateResponseType(); @Override String getQueryName(); @Override ResponseType<I> getResponseType(); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override Q getPayload(); @Override Class<Q> getPayloadType(); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> withMetaData(Map<String, ?> metaData); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> andMetaData(Map<String, ?> metaData); }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public ResponseType<I> getResponseType() { return grpcBackedQueryMessage.getResponseType(); } GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                              Serializer messageSerializer,
                                              Serializer serializer); private  GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                               GrpcBackedQueryMessage<Q, I> grpcBackedQueryMessage,
                                               LazyDeserializingObject<ResponseType<U>> serializedUpdateResponseType); @Override ResponseType<U> getUpdateResponseType(); @Override String getQueryName(); @Override ResponseType<I> getResponseType(); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override Q getPayload(); @Override Class<Q> getPayloadType(); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> withMetaData(Map<String, ?> metaData); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> andMetaData(Map<String, ?> metaData);  }