wheat-cache/pkg/middle/send.go

package middle

import "fmt"

type Send struct {
	ch chan *data
}

func NewSend() *Send {
	return &Send{
		make(chan *data),
	}
}

func (m *Send) Put(msg Msg) {
	da := NewData()
	da.Put("1", msg)
	fmt.Println("传入Send")
	m.ch <- da
}

func (m *Send) Out() Msg {
	return <-m.ch
}