Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- func main() {
- flag.Usage = usage
- flag.Parse()
- if *ffHelp {
- flag.Usage()
- os.Exit(0)
- }
- clients := map[int]string{0: "127.0.0.1:65533", 1: "127.0.0.1:65534"}
- // Network Layer
- netLayer := NL.NewNetworkLayer("tcp", clients[*client])
- go netLayer.Listen()
- fmt.Printf("Listening on %s\n", clients[*client])
- client := Client{ClientID: "42", ClientSeq: 0, netLayer: &netLayer}
- next := make(chan struct{})
- go func() {
- for {
- client.bankMsg()
- <-next
- }
- }()
- for {
- rsp := <-netLayer.RspChan
- var val bank.TransactionResult
- json.Unmarshal(rsp.Msg.Data, &val)
- fmt.Printf("\nValueType: %v\n", val)
- next <- struct{}{}
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement