Struct googapis::google::assistant::embedded::v1alpha2::embedded_assistant_client::EmbeddedAssistantClient

pub struct EmbeddedAssistantClient<T> { /* fields omitted */ }

Service that implements the Google Assistant API.

Implementations

impl<T> EmbeddedAssistantClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as Body>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor<F>(
    inner: T,
    interceptor: F
) -> EmbeddedAssistantClient<InterceptedService<T, F>> where
    F: Interceptor,
    T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
    <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync, 

pub fn send_gzip(self) -> Self

Compress requests with gzip.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_gzip(self) -> Self

Enable decompressing responses with gzip.

pub async fn assist(
    &mut self,
    request: impl IntoStreamingRequest<Message = AssistRequest>
) -> Result<Response<Streaming<AssistResponse>>, Status>

Initiates or continues a conversation with the embedded Assistant Service. Each call performs one round-trip, sending an audio request to the service and receiving the audio response. Uses bidirectional streaming to receive results, such as the END_OF_UTTERANCE event, while sending audio.

A conversation is one or more gRPC connections, each consisting of several streamed requests and responses. For example, the user says Add to my shopping list and the Assistant responds What do you want to add?. The sequence of streamed requests and responses in the first gRPC message could be:

• AssistRequest.config
• AssistRequest.audio_in
• AssistRequest.audio_in
• AssistRequest.audio_in
• AssistRequest.audio_in
• AssistResponse.event_type.END_OF_UTTERANCE
• AssistResponse.speech_results.transcript “add to my shopping list”
• AssistResponse.dialog_state_out.microphone_mode.DIALOG_FOLLOW_ON
• AssistResponse.audio_out
• AssistResponse.audio_out
• AssistResponse.audio_out

The user then says bagels and the Assistant responds OK, I’ve added bagels to your shopping list. This is sent as another gRPC connection call to the Assist method, again with streamed requests and responses, such as:

• AssistRequest.config
• AssistRequest.audio_in
• AssistRequest.audio_in
• AssistRequest.audio_in
• AssistResponse.event_type.END_OF_UTTERANCE
• AssistResponse.dialog_state_out.microphone_mode.CLOSE_MICROPHONE
• AssistResponse.audio_out
• AssistResponse.audio_out
• AssistResponse.audio_out
• AssistResponse.audio_out

Although the precise order of responses is not guaranteed, sequential AssistResponse.audio_out messages will always contain sequential portions of audio.

Trait Implementations

impl<T: Clone> Clone for EmbeddedAssistantClient<T>

fn clone(&self) -> EmbeddedAssistantClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for EmbeddedAssistantClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.