Starts reading the reply

<p>A successful completion will have a single value:

<pre>
r
</pre>
481159
public void startReply()
        throws Throwable
    {
        int tag = read();

        if (tag != 'r')
            error("expected hessian reply at " + codeName(tag));

        int major = read();
        int minor = read();

        startReplyBody();
    }
809060
public Reply read()
        throws ServerException, IOException, FTPReplyParseException, EOFException {

        Reply reply = new Reply(ftpIn);
        //System.out.println("FTP IN string "+reply.toString());
        if (logger.isDebugEnabled()) {
            logger.debug("Control channel received: " + reply);
        }
        lastReply = reply;
        return reply;
    }
913341
public static void pickupFromResponse(RpcInvokeContext context, SofaResponse response, boolean init) {
        if (context == null && !init) {
            return;
        }
        Map<String, String> responseBaggage = response.getResponseProps();
        if (CommonUtils.isNotEmpty(responseBaggage)) {
            String prefix = RemotingConstants.RPC_RESPONSE_BAGGAGE + ".";
            for (Map.Entry<String, String> entry : responseBaggage.entrySet()) {
                if (entry.getKey().startsWith(prefix)) {
                    if (context == null) {
                        context = RpcInvokeContext.getContext();
                    }
                    context.putResponseBaggage(entry.getKey().substring(prefix.length()),
                        entry.getValue());
                }
            }
        }
    }
210993
@Override
	public boolean accept(final Object t) {

		final boolean result = count >= start && count < end;

		count++;

		return result;
	}
1162732
public ResponseOnSingeRequest onComplete(Response response) {

        cancelCancellable();
        try {
            
            Map<String, List<String>> responseHeaders = null;
            if (responseHeaderMeta != null) {
                responseHeaders = new LinkedHashMap<String, List<String>>();
                if (responseHeaderMeta.isGetAll()) {
                    for (Map.Entry<String, List<String>> header : response
                            .getHeaders()) {
                        responseHeaders.put(header.getKey().toLowerCase(Locale.ROOT), header.getValue());
                    }
                } else {
                    for (String key : responseHeaderMeta.getKeys()) {
                        if (response.getHeaders().containsKey(key)) {
                            responseHeaders.put(key.toLowerCase(Locale.ROOT),
                                    response.getHeaders().get(key));
                        }
                    }
                }
            }

            int statusCodeInt = response.getStatusCode();
            String statusCode = statusCodeInt + " " + response.getStatusText();
            String charset = ParallecGlobalConfig.httpResponseBodyCharsetUsesResponseContentType &&
                    response.getContentType()!=null ? 
                    AsyncHttpProviderUtils.parseCharset(response.getContentType())
                    : ParallecGlobalConfig.httpResponseBodyDefaultCharset;
            if(charset == null){
                getLogger().error("charset is not provided from response content type. Use default");
                charset = ParallecGlobalConfig.httpResponseBodyDefaultCharset; 
            }
            reply(response.getResponseBody(charset), false, null, null, statusCode,
                    statusCodeInt, responseHeaders);
        } catch (IOException e) {
            getLogger().error("fail response.getResponseBody " + e);
        }

        return null;
    }
396848
public void finishParsingAndReset() {
        if (queryRowObservable != null) {
            queryRowObservable.onCompleted();
        }
        if (queryInfoObservable != null) {
            queryInfoObservable.onCompleted();
        }
        if (queryErrorObservable != null) {
            queryErrorObservable.onCompleted();
        }
        if (queryStatusObservable != null) {
            queryStatusObservable.onCompleted();
        }
        if (querySignatureObservable != null) {
            querySignatureObservable.onCompleted();
        }
        if (queryProfileInfoObservable != null) {
            queryProfileInfoObservable.onCompleted();
        }
        queryInfoObservable = null;
        queryRowObservable = null;
        queryErrorObservable = null;
        queryStatusObservable = null;
        querySignatureObservable = null;
        queryProfileInfoObservable = null;
        this.initialized = false;
    }
1038688
private void getRead() {
		// Execute on background thread as we don't know how large this is
		new AsyncTask<Void, Void, Void>() {
			@Override
			protected Void doInBackground(Void... params) {
				int size = mPrefs.getInt("READ_ARRAY_SIZE", 0);
				boolean value;
				if(size < 1)
					return null;

				for(int i = 0, key; i < size; i++) {
					key = mPrefs.getInt("READ_ARRAY_KEY_" + i, 0);
					value = mPrefs.getBoolean("READ_ARRAY_VALUE_" + i, false);

					readList.put(key, value);
				}
				return null;
			}
		}.executeOnExecutor(AsyncTask.SERIAL_EXECUTOR);
	}
588823
public DeliverSmResp deliverSmResp(byte[] b) {
        DeliverSmResp resp = new DeliverSmResp();
        SequentialBytesReader reader = new SequentialBytesReader(b);
        assignHeader(resp, reader);
        // ignore the message_id, because it unused.
        return resp;
    }
987276
def readSentence(self):
        
        sentence = tuple(word for word in iter(self.readWord, b''))
        self.log('--->', *sentence)
        reply_word, words = sentence[0], sentence[1:]
        if reply_word == '!fatal':
            self.transport.close()
            raise FatalError(words[0])
        else:
            return reply_word, words
1367676
def read r
      if @m
        res = @m[r]
        return res if res
        
        # Falling back on IO.read - mmap failed"
        @m = nil
      end
      
      @io.sysseek(r.first, IO::SEEK_SET)
      return @io.sysread(r.last-r.first+1)
    end
681124
def _readResponse(self):
        
        traps = []
        reply_word = None
        while reply_word != '!done':
            reply_word, words = self._readSentence()
            if reply_word == '!trap':
                traps.append(TrapError(**words))
            elif reply_word in ('!re', '!done') and words:
                yield words

        if len(traps) > 1:
            raise MultiTrapError(*traps)
        elif len(traps) == 1:
            raise traps[0]
979143
function(result) {
        // start the previous reader listing again
        Espruino.Core.Serial.startListening(prevReader);
        // forward the original text to the previous reader
        if(prevReader) prevReader(receivedData);
        // run the callback
        callback(result);
      }
222955
void readFrom(InputStream in) throws IOException {
		//TODO could optimize for aligned instances
		final int size = finish - start;
		final int length = (size + 7) >> 3;
		if (length == 0) return;
		int p = size & 7;
		final int q = finish - p;
		if (p != 0) performAdj(SET, q, (long) in.read(), p);
		p = q;
		while (p > start) {
			p -= 8;
			performAdj(SET, p, (long) in.read(), 8);
		}
	}
985936
@Override
	public void complete(final LineReader reader, final ParsedLine line, final List<Candidate> candidates) {
		String buffer = line.line().substring(0, line.cursor());
		String[] parts = getLineParts(buffer);
		int len = parts.length;

		// コード補完する引数の番号を特定。
		int startArgNo = getStartArgNo(line);

		// 対象引数が-1、または開始引数にlenが満たない場合は該当なしなのでコード補完しない
		if (!accept(startArgNo, buffer, len)) {
			return;
		}

		boolean isBlank = buffer.endsWith(" ");
		String tableNamePattern = "%";
		if (len == startArgNo && isBlank) {
			tableNamePattern = "%";
		} else if (len == startArgNo + 1 && !isBlank) {
			tableNamePattern = parts[len - 1] + "%";
		} else {
			return;
		}

		try {
			Connection conn = connectionSupplier.getConnection();
			DatabaseMetaData md = conn.getMetaData();
			try (ResultSet rs = md.getTables(conn.getCatalog(), conn.getSchema(),
					tableNamePattern.toUpperCase(), null)) {
				while (rs.next()) {
					candidates.add(new Candidate(rs.getString("TABLE_NAME")));
				}
			}
			if (candidates.isEmpty()) {
				try (ResultSet rs = md.getTables(conn.getCatalog(), conn.getSchema(),
						tableNamePattern.toLowerCase(), null)) {
					while (rs.next()) {
						candidates.add(new Candidate(rs.getString("TABLE_NAME")));
					}
				}
			}
		} catch (SQLException ex) {
			ex.printStackTrace();
			return;
		}
	}
360015
@Override
    public void readFragmentFrom(MwsReader r) {
        payment = r.read("Payment", Money.class);
        paymentMethod = r.read("PaymentMethod", String.class);
    }
355569
private static void parse(final Reader r) throws IOException {
		final BufferedReader br = new BufferedReader(r);
		String line;
		final ArrayList<String> sequence = new ArrayList<String>();

		line = br.readLine();
		while (true) {
			if (line == null) {
				break;
			}
			line = line.trim();
			if (line.length() == 0 || line.charAt(0) == '#') {
				line = br.readLine();
				continue;
			}
			sequence.add(line);

			// read the following lines until a line does not begin with '>' or
			// EOF
			while (true) {
				line = br.readLine();
				if (line == null) {
					addEntry(sequence);
					sequence.clear();
					break;
				}
				line = line.trim();
				if (line.length() == 0 || line.charAt(0) == '#') {
					continue;
				}
				if (line.charAt(0) != '>') {
					addEntry(sequence);
					sequence.clear();
					break;
				}
				sequence.add(line);
			}
		}
		if (!sequence.isEmpty()) {
			addEntry(sequence);
		}
	}
932479
private int completeRead(int b) throws IOException, StreamIntegrityException {
    if (b == END_OF_STREAM) {
      handleEndOfStream();
    } else {
      // Have we reached the end of the stream?
      int c = pushbackInputStream.read();
      if (c == END_OF_STREAM) {
        handleEndOfStream();
      } else {
        pushbackInputStream.unread(c);
      }
    }

    return b;
  }