equal
deleted
inserted
replaced
56 public boolean acceptsMessages() { |
56 public boolean acceptsMessages() { |
57 return callback.acceptsMessages(); |
57 return callback.acceptsMessages(); |
58 } |
58 } |
59 |
59 |
60 /** |
60 /** |
61 * Runs a cycle of doing a beforeRead action and then enqueing a new |
61 * Runs a cycle of doing a beforeRead action and then inquiring a new |
62 * read on the client. Handles closed channels and errors while reading. |
62 * read on the client. Handles closed channels and errors while reading. |
63 * If the client is still connected a new round of actions are called. |
63 * If the client is still connected a new round of actions are called. |
64 */ |
64 */ |
65 public void run(final Client client) { |
65 public void run(final Client client) { |
66 callback.beforeRead(client); |
66 callback.beforeRead(client); |