| 提交 | 用户 | age | ||
| 9d4b12 | 1 | package deliver |
| Z | 2 | |
| 3 | // Deliver define a interface how to use mangos | |
| 4 | type Deliver interface { | |
| 5 | ||
| 6 | // Send send data | |
| 7 | Send([]byte) error | |
| 8 | ||
| 9 | // Recv recv data | |
| 10 | Recv() ([]byte, error) | |
| aaae99 | 11 | |
| Z | 12 | // Close close Deliver |
| 13 | Close() | |
| 9d4b12 | 14 | } |
| Z | 15 | |
| e6cfa5 | 16 | // NewPush create listener args presentive for parameter with protocal, e.g. sub topic |
| Z | 17 | func NewPush(m Mode, url string, args ...interface{}) Deliver { |
| 9d4b12 | 18 | |
| Z | 19 | if m > ModeStart && m < ModeNNG { |
| e6cfa5 | 20 | return nngPush(m, url, args...) |
| 9d4b12 | 21 | } |
| Z | 22 | return nil |
| 23 | } | |
| 24 | ||
| e6cfa5 | 25 | // NewPull create dialer args presentive for parameter with protocal, e.g. sub topic |
| Z | 26 | func NewPull(m Mode, url string, args ...interface{}) Deliver { |
| 9d4b12 | 27 | |
| Z | 28 | if m > ModeStart && m < ModeNNG { |
| e6cfa5 | 29 | return nngPull(m, url, args...) |
| 9d4b12 | 30 | } |
| Z | 31 | |
| 32 | return nil | |
| 33 | } | |
