Skip to content

Commit 98bc2dc

Browse files
committed
Merge remote-tracking branch 'origin/main' into springboot-4
2 parents f77b5bc + 79248f7 commit 98bc2dc

4 files changed

Lines changed: 4 additions & 2 deletions

File tree

util/api/datasourcex-util.api

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ public final class com/caplin/integration/datasourcex/util/flow/FlatMapFirstKt {
181181
}
182182

183183
public abstract interface class com/caplin/integration/datasourcex/util/flow/FlowMap : com/caplin/integration/datasourcex/util/flow/MapFlow, java/util/Map, kotlin/jvm/internal/markers/KMappedMarker {
184-
public abstract fun asMap ()Lkotlinx/collections/immutable/PersistentMap;
184+
public abstract fun asMap ()Ljava/util/Map;
185185
}
186186

187187
public final class com/caplin/integration/datasourcex/util/flow/FlowMapKt {

util/src/main/kotlin/com/caplin/integration/datasourcex/util/flow/FlowMap.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ interface MutableFlowMap<K : Any, V : Any> : FlowMap<K, V> {
8080
interface FlowMap<K : Any, V : Any> : MapFlow<K, V>, Map<K, V> {
8181

8282
/** A copy of the map at this point in time */
83-
fun asMap(): PersistentMap<K, V>
83+
fun asMap(): Map<K, V>
8484
}
8585

8686
/** An event emitted by [MapFlow.asFlowWithState]. */

util/src/main/kotlin/com/caplin/integration/datasourcex/util/serialization/jackson2/FlowMapStreamEventDeserializer.kt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import com.fasterxml.jackson.databind.node.ObjectNode
1010

1111
internal class FlowMapStreamEventDeserializer :
1212
StdDeserializer<FlowMapStreamEvent<*, *>>(FlowMapStreamEvent::class.java) {
13+
@Suppress("UNCHECKED_CAST")
1314
override fun deserialize(p: JsonParser, ctxt: DeserializationContext): FlowMapStreamEvent<*, *> {
1415
val node = p.codec.readTree<ObjectNode>(p)
1516
val type =

util/src/main/kotlin/com/caplin/integration/datasourcex/util/serialization/jackson3/FlowMapStreamEventDeserializer.kt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import tools.jackson.databind.deser.std.StdDeserializer
99

1010
internal class FlowMapStreamEventDeserializer :
1111
StdDeserializer<FlowMapStreamEvent<*, *>>(FlowMapStreamEvent::class.java) {
12+
@Suppress("UNCHECKED_CAST")
1213
override fun deserialize(p: JsonParser, ctxt: DeserializationContext): FlowMapStreamEvent<*, *> {
1314
val node = ctxt.readTree(p)
1415
val type =

0 commit comments

Comments
 (0)