131         let mut b = self.buffer.lock().await;  in write()  localVariable
133         if b.closed {  in write()
137         if (b.limit_count > 0 && b.count >= b.limit_count)  in write()
138             || (b.limit_size > 0 && b.size() + 2 + packet.len() > b.limit_size)  in write()
144         while !b.available(packet.len()) {  in write()
145             b.grow()?;  in write()
149         let tail = b.tail;  in write()
150         b.data[tail] = (packet.len() >> 8) as u8;  in write()
151         b.tail += 1;  in write()
152         if b.tail >= b.data.len() {  in write()
153             b.tail = 0;  in write()
156         let tail = b.tail;  in write()
157         b.data[tail] = packet.len() as u8;  in write()
158         b.tail += 1;  in write()
159         if b.tail >= b.data.len() {  in write()
160             b.tail = 0;  in write()
164         let end = std::cmp::min(b.data.len(), b.tail + packet.len());  in write()
165         let n = end - b.tail;  in write()
166         let tail = b.tail;  in write()
167         b.data[tail..end].copy_from_slice(&packet[..n]);  in write()
168         b.tail += n;  in write()
169         if b.tail >= b.data.len() {  in write()
172             b.data[..m].copy_from_slice(&packet[n..]);  in write()
173             b.tail = m;  in write()
175         b.count += 1;  in write()
177         if b.subs {  in write()
180             b.subs = false;  in write()
194                 let mut b = self.buffer.lock().await;  in read()  localVariable
196                 if b.head != b.tail {  in read()
198                     let n1 = b.data[b.head];  in read()
199                     b.head += 1;  in read()
200                     if b.head >= b.data.len() {  in read()
201                         b.head = 0;  in read()
203                     let n2 = b.data[b.head];  in read()
204                     b.head += 1;  in read()
205                     if b.head >= b.data.len() {  in read()
206                         b.head = 0;  in read()
217                     if b.head + copied < b.data.len() {  in read()
218                         packet[..copied].copy_from_slice(&b.data[b.head..b.head + copied]);  in read()
220                         let k = b.data.len() - b.head;  in read()
221                         packet[..k].copy_from_slice(&b.data[b.head..]);  in read()
222                         packet[k..copied].copy_from_slice(&b.data[..copied - k]);  in read()
226                     b.head += count;  in read()
227                     if b.head >= b.data.len() {  in read()
228                         b.head -= b.data.len();  in read()
231                     if b.head == b.tail {  in read()
234                         b.head = 0;  in read()
235                         b.tail = 0;  in read()
238                     b.count -= 1;  in read()
246                     b.subs = true;  in read()
249                 if b.closed {  in read()
270         let mut b = self.buffer.lock().await;  in close()  localVariable
272         if b.closed {  in close()
276         b.closed = true;  in close()
281         let b = self.buffer.lock().await;  in is_closed()  localVariable
283         b.closed  in is_closed()
288         let b = self.buffer.lock().await;  in count()  localVariable
290         b.count  in count()
297         let mut b = self.buffer.lock().await;  in set_limit_count()  localVariable
299         b.limit_count = limit  in set_limit_count()
304         let b = self.buffer.lock().await;  in size()  localVariable
306         b.size()  in size()
317         let mut b = self.buffer.lock().await;  in set_limit_size()  localVariable
319         b.limit_size = limit  in set_limit_size()