Searched refs:_cur (Results 1 – 4 of 4) sorted by relevance
165 self._cur = None202 if self._cur and self._cur.get_content_type() == 'multipart/digest':207 self._cur = msg213 self._cur = self._msgstack[-1]215 self._cur = None234 self.policy.handle_defect(self._cur, defect)254 self._cur.set_payload(EMPTYSTRING.join(lines))256 if self._cur.get_content_type() == 'message/delivery-status':295 if self._cur.get_content_maintype() == 'message':305 if self._cur.get_content_maintype() == 'multipart':[all …]
167 self._cur = None200 if self._cur and self._cur.get_content_type() == 'multipart/digest':205 self._cur = msg211 self._cur = self._msgstack[-1]213 self._cur = None250 self._cur.set_payload(EMPTYSTRING.join(lines))252 if self._cur.get_content_type() == 'message/delivery-status':291 if self._cur.get_content_maintype() == 'message':301 if self._cur.get_content_maintype() == 'multipart':302 boundary = self._cur.get_boundary()[all …]
33 private val _cur = atomic(Core<E>(Core.INITIAL_CAPACITY, singleConsumer)) in <lambda>() constant36 val isEmpty: Boolean get() = _cur.value.isEmpty in <lambda>()37 val size: Int get() = _cur.value.size in <lambda>()40 _cur.loop { cur -> in <lambda>()42 _cur.compareAndSet(cur, cur.next()) // move to next in <lambda>()47 _cur.loop { cur -> in <lambda>()51 Core.ADD_FROZEN -> _cur.compareAndSet(cur, cur.next()) // move to next in <lambda>()58 _cur.loop { cur -> in <lambda>()61 _cur.compareAndSet(cur, cur.next()) in <lambda>()66 fun <R> map(transform: (E) -> R): List<R> = _cur.value.map(transform) in <lambda>()[all …]
73 self._cur = 088 self._cur += x98 barlen = int(20 * self._cur / float(self._amount))103 text = self.TEXT.format(self._name, bartext, self._cur, self._amount)