(local *RESPHandle.WriterHandle, reply string)
| 28 | ) |
| 29 | |
| 30 | func WriteSimpleString(local *RESPHandle.WriterHandle, reply string) error { |
| 31 | err := local.WriteSimpleString(reply) |
| 32 | if err != nil { |
| 33 | logrus.Error("client write error:", err) |
| 34 | return ErrLocalWriter |
| 35 | } |
| 36 | err = local.Flush() |
| 37 | if err != nil { |
| 38 | logrus.Error("Client flush error:", err) |
| 39 | return ErrLocalFlush |
| 40 | } |
| 41 | return nil |
| 42 | } |
| 43 | |
| 44 | func WriteBulk(local *RESPHandle.WriterHandle, reply []byte) error { |
| 45 | err := local.WriteBulk(reply) |
no test coverage detected