wheat-cache/pkg/middle/upload.go

package middle

import "fmt"

type Upload struct {
	ch chan *data
}

func NewUpload() *Upload {
	return &Upload{
		make(chan *data),
	}
}

func (m *Upload) Put(msg Msg) {
	da := NewData()
	da.Put("1", msg)
	fmt.Println("传入Upload")

	m.ch <- da
}

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