d74becc41c1ce371a352db3620327156d9607252
Files Diff
- Added: 4
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type sink : MonoSink<QueryResponseMessage<I>> to sink : MonoSink<QueryResponse> in method private initialResult(sink MonoSink<QueryResponse>, publisher Publisher<SubscriptionQueryRequest>) : void in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Change Parameter Type query : SubscriptionQueryMessage<Q,I,U> to query : SubscriptionQuery in method package AxonHubSubscriptionQueryResult(query SubscriptionQuery, openStreamFn Function<StreamObserver<SubscriptionQueryResponse>,StreamObserver<SubscriptionQueryRequest>>, configuration AxonHubConfiguration, backPressure SubscriptionQueryBackpressure, bufferSize int, onDispose Runnable) in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Change Return Type | 1 | ||
| Change Return Type SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> to SubscriptionQueryResult<QueryResponse,QueryUpdate> in method public get() : SubscriptionQueryResult<QueryResponse,QueryUpdate> in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private serializer : SubscriptionMessageSerializer from class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult to private serializer : SubscriptionMessageSerializer from class io.axoniq.axonhub.client.query.subscription.DeserializedResult | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type mono : Mono<QueryResponseMessage<I>> to mono : Mono<QueryResponse> in method package AxonHubSubscriptionQueryResult(query SubscriptionQuery, openStreamFn Function<StreamObserver<SubscriptionQueryResponse>,StreamObserver<SubscriptionQueryRequest>>, configuration AxonHubConfiguration, backPressure SubscriptionQueryBackpressure, bufferSize int, onDispose Runnable) in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Change Variable Type processor : EmitterProcessor<SubscriptionQueryUpdateMessage<U>> to processor : EmitterProcessor<QueryUpdate> in method package AxonHubSubscriptionQueryResult(query SubscriptionQuery, openStreamFn Function<StreamObserver<SubscriptionQueryResponse>,StreamObserver<SubscriptionQueryRequest>>, configuration AxonHubConfiguration, backPressure SubscriptionQueryBackpressure, bufferSize int, onDispose Runnable) in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Extract Method | 2 | ||
| Extract Method private completeExceptionally(t Throwable) : void extracted from public onError(t Throwable) : void in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Extract Method private complete() : void extracted from public onCompleted() : void in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type initialResultSink : MonoSink<QueryResponseMessage<I>> to initialResultSink : MonoSink<QueryResponse> in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Change Attribute Type result : SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> to result : SubscriptionQueryResult<QueryResponse,QueryUpdate> in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To | |
| Change Attribute Type updateMessageFluxSink : FluxSink<SubscriptionQueryUpdateMessage<U>> to updateMessageFluxSink : FluxSink<QueryUpdate> in class io.axoniq.axonhub.client.query.subscription.AxonHubSubscriptionQueryResult | From | To |