client.go

package main

import (
        "fmt"

        "github.com/micro/clients/go/client"
)

type Request struct {
        Count string `json:"count"`
}

type Response struct {
        Count string `json:"count"`
}

func main() {
        c := client.NewClient(nil)

        stream, err := c.Stream("go.micro.srv.asim", "Asim.Stream", Request{Count: "10"})
        if err != nil {
                fmt.Println(err)
                return
        }

        for {
                var rsp Response
                if err := stream.Recv(&rsp); err != nil {
                        fmt.Println(err)
                        return
                }
                fmt.Println("got", rsp.Count)
        }
}