JsonStreamMediaTypeCodec.java
/*
* Copyright 2017-2020 original authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.micronaut.json.codec;
import io.micronaut.context.BeanProvider;
import io.micronaut.context.annotation.BootstrapContextCompatible;
import io.micronaut.core.annotation.Experimental;
import io.micronaut.core.annotation.Nullable;
import io.micronaut.http.MediaType;
import io.micronaut.http.codec.CodecConfiguration;
import io.micronaut.json.JsonMapper;
import io.micronaut.runtime.ApplicationConfiguration;
import jakarta.inject.Inject;
import jakarta.inject.Named;
import jakarta.inject.Singleton;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
/**
* A codec for {@link MediaType#APPLICATION_JSON_STREAM}.
*
* @author Graeme Rocher
* @since 1.0
* @deprecated Replaced with message body writers / readers API
*/
@Experimental
@Singleton
@BootstrapContextCompatible
@Deprecated(forRemoval = true, since = "4.7")
public class JsonStreamMediaTypeCodec extends JsonMediaTypeCodec {
public static final String CONFIGURATION_QUALIFIER = "json-stream";
private final List<MediaType> streamAdditionalTypes;
/**
* @param jsonMapper To read/write JSON
* @param applicationConfiguration The common application configurations
* @param codecConfiguration The configuration for the codec
*/
public JsonStreamMediaTypeCodec(JsonMapper jsonMapper,
ApplicationConfiguration applicationConfiguration,
@Named(CONFIGURATION_QUALIFIER) @Nullable CodecConfiguration codecConfiguration) {
super(jsonMapper, applicationConfiguration, null);
if (codecConfiguration != null) {
this.streamAdditionalTypes = codecConfiguration.getAdditionalTypes();
} else {
this.streamAdditionalTypes = Collections.emptyList();
}
}
/**
* @param jsonCodec To read/write JSON
* @param applicationConfiguration The common application configurations
* @param codecConfiguration The configuration for the codec
*/
@Inject
public JsonStreamMediaTypeCodec(BeanProvider<JsonMapper> jsonCodec,
ApplicationConfiguration applicationConfiguration,
@Named(CONFIGURATION_QUALIFIER) @Nullable CodecConfiguration codecConfiguration) {
super(jsonCodec, applicationConfiguration, null);
if (codecConfiguration != null) {
this.streamAdditionalTypes = codecConfiguration.getAdditionalTypes();
} else {
this.streamAdditionalTypes = Collections.emptyList();
}
}
@Override
public Collection<MediaType> getMediaTypes() {
var mediaTypes = new ArrayList<MediaType>();
mediaTypes.add(MediaType.APPLICATION_JSON_STREAM_TYPE);
mediaTypes.addAll(streamAdditionalTypes);
return mediaTypes;
}
@Override
protected MapperMediaTypeCodec cloneWithMapper(JsonMapper mapper) {
return new JsonStreamMediaTypeCodec(mapper, applicationConfiguration, codecConfiguration);
}
}