feat: Updated pkg/rpcclient/conversation.go

2 years ago · fd729450a4
parent e7daec0f48
commit fd729450a4
1 changed files with 2 additions and 2 deletions
--- a/pkg/rpcclient/conversation.go
+++ b/pkg/rpcclient/conversation.go
@ -38,8 +38,8 @@ func NewConversation(discov discoveryregistry.SvcDiscoveryRegistry) *Conversatio
 	if err != nil {
 		panic(err)
 	}
-	client := pbconversation.NewConversationClient(conn)
-	return &Conversation{discov: discov, conn: conn, Client: client}
+	client := pbconversation.NewConversationClient(conn.(dubbo-go.ClientConnInterface))
+	return &Conversation{discov: discov, conn: conn.(dubbo-go.ClientConnInterface), Client: client}
 }

 type ConversationRpcClient Conversation