Модифицированная ручка Flux, тип возврата - PullRequest
Новая
       6

Модифицированная ручка Flux, тип возврата

0 голосов
/ 26 октября 2018

Как обрабатывать возвращаемый тип Flux при модернизации?

EndPointApi 

public interface DataEndPointApi {
   @GET( "ap1/v3/data")
   Flux<Data> getAllData(@Query( "dataType") String dataType);
}

RetroRestAdapter 

@Autowired
private ObjectMapper objectMapper;

RestAdapter retrofit = new RestAdapter.Builder()
         .setEndpoint( "http://localhost:8080" )
         .setConverter( new JacksonConverter( this.objectMapper ) )         
         .build();

Звонящий 

DatasourceEndPointApi datasourceEndPointApi;
Flux<Data> dataFlux = this.dataEndPointApi.getAllData( "GREETING" );

Я получаю ниже ошибки

Ошибка 

retrofit.RetrofitError: com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Cannot construct instance of `reactor.core.publisher.Flux` (no Creators, like default construct, exist): abstract types either need to be mapped to concrete types, have custom deserializer, or contain additional type information
 at [Source: (retrofit.ExceptionCatchingTypedInput$ExceptionCatchingInputStream); line: 1, column: 1]
    at retrofit.RetrofitError.conversionError(RetrofitError.java:33)
    at retrofit.RestAdapter$RestHandler.invokeRequest(RestAdapter.java:383)
    at retrofit.RestAdapter$RestHandler.invoke(RestAdapter.java:240)
    at com.sun.proxy.$Proxy153.getAllDatasource(Unknown Source)
    at

Итак, как я могу справитьсяТип возврата потока в модификации?

...