diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-29 00:58:01 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-29 00:58:01 +0300 |
| commit | c55afd2de177f128fae6e1c52d0c56af17096258 (patch) | |
| tree | 2b06eeabf4db3a6c7ef357fb1569c4e8f72aab68 /pkg/server/hook/alpha.go | |
| parent | 11501b56a751d2959480aaeaf2036eff586e5629 (diff) | |
rename module to hook
Diffstat (limited to 'pkg/server/hook/alpha.go')
| -rw-r--r-- | pkg/server/hook/alpha.go | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/pkg/server/hook/alpha.go b/pkg/server/hook/alpha.go new file mode 100644 index 0000000..d1fefcc --- /dev/null +++ b/pkg/server/hook/alpha.go @@ -0,0 +1,32 @@ +package hook + +import ( + "bufio" + "io" + "tunnel/pkg/server/queue" + "unicode" +) + +func alpha(cb func(rune) rune) Func { + return func(rq, wq queue.Q) error { + r := bufio.NewReader(rq.Reader()) + + for { + c, _, err := r.ReadRune() + if err != nil { + if err == io.EOF { + break + } + return err + } + wq <- []byte(string(cb(c))) + } + + return nil + } +} + +func init() { + registerFunc("lower", alpha(unicode.ToLower)) + registerFunc("upper", alpha(unicode.ToUpper)) +} |
