| open Thrift | |
| module T = Transport | |
| class t (i,o) = | |
| object (self) | |
| val mutable opened = true | |
| inherit Transport.t | |
| method isOpen = opened | |
| method opn = () | |
| method close = close_in i; opened <- false | |
| method read buf off len = | |
| if opened then | |
| try | |
| really_input i buf off len; len | |
| with _ -> raise (T.E (T.UNKNOWN, ("TChannelTransport: Could not read "^(string_of_int len)))) | |
| else | |
| raise (T.E (T.NOT_OPEN, "TChannelTransport: Channel was closed")) | |
| method write buf off len = output o buf off len | |
| method flush = flush o | |
| end |