(buf []byte)
| 77 | } |
| 78 | |
| 79 | func (t *TelnetSession) doWrite(buf []byte) (int, error) { |
| 80 | obj, err := async.WithTimeout(t.timeouts.Write, func() interface{} { |
| 81 | n, err := t.client.Write(buf) |
| 82 | return rw{e: err, n: n} |
| 83 | }) |
| 84 | if err != nil { |
| 85 | return -1, err |
| 86 | } |
| 87 | |
| 88 | w := obj.(rw) |
| 89 | return w.n, w.e |
| 90 | } |
| 91 | |
| 92 | func (t *TelnetSession) doReadUntil(s string) (error, string) { |
| 93 | log.Debug("doReadUntil(%s)", s) |