unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 2 Actions Packages Projects Releases 288 Wiki Activity

Update to use actual values passed through the chain

Browse Source
This commit is contained in:
Asim 2015-12-02 20:11:00 +00:00
parent ef8303f11f
commit 4b18b779aa
2 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
examples/client/pub/pub.go
View File

@ -2,7 +2,6 @@ package main
import (
"fmt"
"time"
"github.com/micro/go-micro/client"
"github.com/micro/go-micro/cmd"
@ -35,11 +34,7 @@ func pub(i int) {
func main() {
cmd.Init()
fmt.Println("\n--- Publisher example ---\n")
// for i := 0; i < 10; i++ {
i := 0
for {
for i := 0; i < 10; i++ {
pub(i)
i++
time.Sleep(time.Millisecond * 5)
}
}

4
server/rpcplus_server.go
View File

@ -238,7 +238,7 @@ func (s *service) call(ctx context.Context, server *server, sending *sync.Mutex,
if !mtype.stream {
fn := func(ctx context.Context, req interface{}, rsp interface{}) error {
returnValues = function.Call([]reflect.Value{s.rcvr, mtype.prepareContext(ctx), argv, replyv})
returnValues = function.Call([]reflect.Value{s.rcvr, mtype.prepareContext(ctx), reflect.ValueOf(req), reflect.ValueOf(rsp)})
// The return value for the method is an error.
if err := returnValues[0].Interface(); err != nil {
@ -300,7 +300,7 @@ func (s *service) call(ctx context.Context, server *server, sending *sync.Mutex,
// Invoke the method, providing a new value for the reply.
fn := func(ctx context.Context, req interface{}, rspFn interface{}) error {
returnValues = function.Call([]reflect.Value{s.rcvr, mtype.prepareContext(ctx), argv, reflect.ValueOf(sendReply)})
returnValues = function.Call([]reflect.Value{s.rcvr, mtype.prepareContext(ctx), reflect.ValueOf(req), reflect.ValueOf(rspFn)})
if err := returnValues[0].Interface(); err != nil {
// the function returned an error, we use that
return err.(error)