Stream speech audio to server as it gets recorded, instead of waiting until end of recording.

content/browser/speech/speech_recognition_request.cc

 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/browser/speech/speech_recognition_request.h"
 
 #include <vector>
 
 #include "base/json/json_reader.h"
 #include "base/string_util.h"
@@ skipping 102 matching lines @@
 
 SpeechRecognitionRequest::SpeechRecognitionRequest(
     URLRequestContextGetter* context, Delegate* delegate)
     : url_context_(context),
       delegate_(delegate) {
   DCHECK(delegate);
 }
 
 SpeechRecognitionRequest::~SpeechRecognitionRequest() {}
 
-bool SpeechRecognitionRequest::Send(const std::string& language,
-                                    const std::string& grammar,
-                                    const std::string& hardware_info,
-                                    const std::string& origin_url,
-                                    const std::string& content_type,
-                                    const std::string& audio_data) {
+void SpeechRecognitionRequest::Start(const std::string& language,
+                                     const std::string& grammar,
+                                     const std::string& hardware_info,
+                                     const std::string& origin_url,
+                                     const std::string& content_type) {
   DCHECK(!url_fetcher_.get());
 
   std::vector<std::string> parts;
 
   std::string lang_param = language;
   if (lang_param.empty() && url_context_) {
     // If no language is provided then we use the first from the accepted
     // language list. If this list is empty then it defaults to "en-US".
     // Example of the contents of this list: "es,en-GB;q=0.8", ""
     net::URLRequestContext* request_context =
@@ skipping 14 matching lines @@
   // TODO(satish): Remove this hardcoded value once the page is allowed to
   // set this via an attribute.
   parts.push_back("maxresults=3");
 
   GURL url(std::string(kDefaultSpeechRecognitionUrl) + JoinString(parts, '&'));
 
   url_fetcher_.reset(URLFetcher::Create(url_fetcher_id_for_tests,
                                         url,
                                         URLFetcher::POST,
                                         this));
-  url_fetcher_->set_upload_data(content_type, audio_data);
+  url_fetcher_->set_chunked_upload(content_type);
   url_fetcher_->set_request_context(url_context_);
   url_fetcher_->set_referrer(origin_url);
 
   // The speech recognition API does not require user identification as part
   // of requests, so we don't send cookies or auth data for these requests to
   // prevent any accidental connection between users who are logged into the
   // domain for other services (e.g. bookmark sync) with the speech requests.
   url_fetcher_->set_load_flags(
       net::LOAD_DO_NOT_SAVE_COOKIES | net::LOAD_DO_NOT_SEND_COOKIES |
       net::LOAD_DO_NOT_SEND_AUTH_DATA);
   url_fetcher_->Start();
-  return true;
+}
+
+void SpeechRecognitionRequest::UploadAudioChunk(const std::string& audio_data,
+                                                bool is_last_chunk) {
+  DCHECK(url_fetcher_.get());
+  url_fetcher_->AppendChunkToUpload(audio_data, is_last_chunk);
 }
 
 void SpeechRecognitionRequest::OnURLFetchComplete(
     const URLFetcher* source,
     const GURL& url,
     const net::URLRequestStatus& status,
     int response_code,
     const ResponseCookies& cookies,
     const std::string& data) {
   DCHECK_EQ(url_fetcher_.get(), source);
 
   bool error = !status.is_success() || response_code != 200;
   SpeechInputResultArray result;
   if (!error)
     error = !ParseServerResponse(data, &result);
   url_fetcher_.reset();
 
   DVLOG(1) << "SpeechRecognitionRequest: Invoking delegate with result.";
   delegate_->SetRecognitionResult(error, result);
 }
 
 }  // namespace speech_input