diff --git a/pkg/middle/Middle.go b/pkg/middle/Middle.go index d70117a..c79d7d3 100644 --- a/pkg/middle/Middle.go +++ b/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 diff --git a/pkg/middle/upload.go b/pkg/middle/upload.go index 94eaada..9e0e0e0 100644 --- a/pkg/middle/upload.go +++ b/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), + } +}