Browse Source

remove unnecessary functions
fix tests

flashmob 6 years ago
parent
commit
f35b5cdf1e
2 changed files with 1 additions and 10 deletions
  1. 1 1
      backends/gateway_test.go
  2. 0 9
      backends/stream_decorate.go

+ 1 - 1
backends/gateway_test.go

@@ -86,7 +86,7 @@ func TestStartProcessStop(t *testing.T) {
 	e.Data.WriteString("Subject:Test\n\nThis is a test.")
 	e.Data.WriteString("Subject:Test\n\nThis is a test.")
 	notify := make(chan *notifyMsg)
 	notify := make(chan *notifyMsg)
 
 
-	gateway.conveyor <- &workerMsg{e, notify, TaskSaveMail}
+	gateway.conveyor <- &workerMsg{e, notify, TaskSaveMail, nil}
 
 
 	// it should not produce any errors
 	// it should not produce any errors
 	// headers (subject) should be parsed.
 	// headers (subject) should be parsed.

+ 0 - 9
backends/stream_decorate.go

@@ -23,12 +23,3 @@ func DecorateStream(c StreamProcessor, ds []*StreamDecorator) (StreamProcessor,
 	}
 	}
 	return c, ds
 	return c, ds
 }
 }
-
-func (sd *StreamDecorator) OpenX(e *mail.Envelope) error {
-	sd.e = e
-	return nil
-}
-
-func (sd *StreamDecorator) Closex() error {
-	return nil
-}