mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

connect if not connected
All checks were successful
Build and Publish / BuildAndDeploy (push) Successful in 1m53s
Details

Browse Source
This commit is contained in:
matst80
2024-11-09 23:40:04 +01:00
parent 52e9a44238
commit 3feaa61248
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
rpc-pool.go
View File

@@ -52,7 +52,11 @@ func (g *RemoteGrain) Connect() error {
} }
func (g *RemoteGrain) HandleMessage(message *Message, isReplay bool) ([]byte, error) { func (g *RemoteGrain) HandleMessage(message *Message, isReplay bool) ([]byte, error) {
err := SendCartPacket(g.connection, g.Id, RemoteHandleMessage, message.Write) err := g.Connect()
if err != nil {
return nil, err
}
err = SendCartPacket(g.connection, g.Id, RemoteHandleMessage, message.Write)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -68,7 +72,11 @@ func (g *RemoteGrain) GetId() CartId {
} }
func (g *RemoteGrain) GetCurrentState() ([]byte, error) { func (g *RemoteGrain) GetCurrentState() ([]byte, error) {
err := SendCartPacket(g.connection, g.Id, RemoteGetState, func(w io.Writer) error { err := g.Connect()
if err != nil {
return nil, err
}
err = SendCartPacket(g.connection, g.Id, RemoteGetState, func(w io.Writer) error {
return nil return nil
}) })
if err != nil { if err != nil {