middle

pkg/middle/Middle.go

@@ -36,26 +36,6 @@ type middleWare interface {
 	Out() Msg
 }
 
-type Upload struct {
-	ch chan *data
-}
-
-func (m *Upload) Put(msg Msg) {
-	da := NewData()
-	da.Put("1", msg)
-	m.ch <- da
-}
-
-func (m *Upload) Out() Msg {
-	return <-m.ch
-}
-
-func NewUpload() *Upload {
-	return &Upload{
-		make(chan *data),
-	}
-}
-
 type MiddlewareConf struct {
 	Weight int
 	Middle middleWare

pkg/middle/upload.go

@@ -1 +1,21 @@
 package middle
+
+type Upload struct {
+	ch chan *data
+}
+
+func (m *Upload) Put(msg Msg) {
+	da := NewData()
+	da.Put("1", msg)
+	m.ch <- da
+}
+
+func (m *Upload) Out() Msg {
+	return <-m.ch
+}
+
+func NewUpload() *Upload {
+	return &Upload{
+		make(chan *data),
+	}
+}