Skip to content

Streaming bug fixes #434

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
vishay wants to merge 3 commits into from
Closed

Streaming bug fixes #434

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
f24b33d
after a single utterance, exit the script
vishay Jul 30, 2016
fbf4141
Fix a bug to correctly exit at the end of a single_utterance, if flag…
vishay Jul 30, 2016
af32d48
Add single_utterance flag as an argument to main.
vishay Jul 30, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
after a single utterance, exit the script
  • Loading branch information
@vishay
vishay committed Jul 30, 2016
commit f24b33d5278a2f2a15077ff7ad4a4f420dbc50e5
7 changes: 6 additions & 1 deletion speech/api/speech_streaming.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
from google.rpc import code_pb2
from grpc.beta import implementations
import pyaudio
from google.cloud.speech.v1beta1.cloud_speech_pb2 import StreamingRecognizeResponse

# Audio recording parameters
RATE = 16000
Expand All @@ -34,6 +35,7 @@
# Keep the request alive for this many seconds
DEADLINE_SECS = 8 * 60 * 60
SPEECH_SCOPE = 'https://www.googleapis.com/auth/cloud-platform'
SINGLE_UTTERANCE = False


def make_channel(host, port):
Expand Down Expand Up @@ -105,7 +107,7 @@ def request_stream(stop_audio, channels=CHANNELS, rate=RATE, chunk=CHUNK):
# re-interprets audio in the context of subsequent audio. However, this
# will give us quick results without having to tell the server when to
# finalize a piece of audio.
interim_results=True, single_utterance=True
interim_results=True, single_utterance=SINGLE_UTTERANCE
)

yield cloud_speech.StreamingRecognizeRequest(
Expand Down Expand Up @@ -138,6 +140,9 @@ def listen_print_loop(recognize_stream):
print('Exiting..')
return

if SINGLE_UTTERANCE and resp.endpointer_type == StreamingRecognizeResponse.END_OF_UTTERANCE:
print ('End of utterance. Exiting...')
return

def main():
stop_audio = threading.Event()
Expand Down