totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-17 13:24:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix join response

Browse Source
This commit is contained in:
Asim Aslam
2022-02-17 16:41:35 +00:00
parent c49ee7e8b1
commit 2bb2bcc4b4
5 changed files with 220 additions and 151 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
chat/proto/chat.pb.micro.go
View File

@@ -132,7 +132,7 @@ type Chat_JoinService interface {
SendMsg(interface{}) error
RecvMsg(interface{}) error
Close() error
Recv() (*Message, error)
Recv() (*JoinResponse, error)
}
type chatServiceJoin struct {
@@ -155,8 +155,8 @@ func (x *chatServiceJoin) RecvMsg(m interface{}) error {
return x.stream.Recv(m)
}
func (x *chatServiceJoin) Recv() (*Message, error) {
m := new(Message)
func (x *chatServiceJoin) Recv() (*JoinResponse, error) {
m := new(JoinResponse)
err := x.stream.Recv(m)
if err != nil {
return nil, err
@@ -264,7 +264,7 @@ type Chat_JoinStream interface {
SendMsg(interface{}) error
RecvMsg(interface{}) error
Close() error
Send(*Message) error
Send(*JoinResponse) error
}
type chatJoinStream struct {
@@ -287,7 +287,7 @@ func (x *chatJoinStream) RecvMsg(m interface{}) error {
return x.stream.Recv(m)
}
func (x *chatJoinStream) Send(m *Message) error {
func (x *chatJoinStream) Send(m *JoinResponse) error {
return x.stream.Send(m)
}