|
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
|
|
}
|