diff options
Diffstat (limited to 'pkg/server/module/split.go')
| -rw-r--r-- | pkg/server/module/split.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/server/module/split.go b/pkg/server/module/split.go index 138814f..139d062 100644 --- a/pkg/server/module/split.go +++ b/pkg/server/module/split.go @@ -34,8 +34,8 @@ func (m *splitModule) Send(rq, wq queue.Q) error { return nil } -func (m *splitModule) Open(env.Env) (Pipe, Pipe) { - return m.Send, nil +func (m *splitModule) Open(env.Env) (interface{}, error) { + return m, nil } func newSplitModule(opts opts.Opts, env env.Env) (module, error) { |