diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-26 02:38:02 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-26 02:38:57 +0300 |
| commit | e6631acaa5af979d87645d74997955a1304cd648 (patch) | |
| tree | ba1a13102d437bc908a7c32ce604a802d5098868 /pkg/server/module/split.go | |
| parent | d6b87d6ad43219bf5b9cdfef50697e1b066dc4ea (diff) | |
[server] prepare module.Open to return error
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) { |