We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 9b67275 + 791af4a commit b712563Copy full SHA for b712563
1 file changed
api/handler_kafka_test.go
@@ -4,6 +4,7 @@ import (
4
"encoding/json"
5
"mokapi/api"
6
"mokapi/config/dynamic"
7
+ "mokapi/config/dynamic/asyncApi"
8
"mokapi/config/dynamic/dynamictest"
9
"mokapi/config/static"
10
"mokapi/engine/enginetest"
@@ -1096,6 +1097,13 @@ func TestHandler_Kafka_Metrics(t *testing.T) {
1096
1097
}
1098
1099
1100
+func Test_IsAsyncApiConfig(t *testing.T) {
1101
+ v2 := &asyncApi.Config{Info: asyncApi.Info{Name: "foo"}}
1102
+ _, ok := runtime.IsAsyncApiConfig(&dynamic.Config{Data: v2})
1103
+ require.True(t, ok)
1104
+
1105
+}
1106
1107
func getKafkaInfo(config *asyncapi3.Config) *runtime.KafkaInfo {
1108
return &runtime.KafkaInfo{
1109
Config: config,
0 commit comments