fn create_stream_processor(
        &self,
        input: CreateStreamProcessorRequest,
    ) -> RusotoFuture<CreateStreamProcessorResponse, CreateStreamProcessorError> {
        let mut request = SignedRequest::new("POST", "rekognition", &self.region, "/");

        request.set_content_type("application/x-amz-json-1.1".to_owned());
        request.add_header("x-amz-target", "RekognitionService.CreateStreamProcessor");
        let encoded = serde_json::to_string(&input).unwrap();
        request.set_payload(Some(encoded.into_bytes()));

        self.client.sign_and_dispatch(request, |response| {
            if response.status.is_success() {
                Box::new(response.buffer().from_err().map(|response| {
                    let mut body = response.body;

                    if body.is_empty() || body == b"null" {
                        body = b"{}".to_vec();
                    }

                    serde_json::from_str::<CreateStreamProcessorResponse>(
                        String::from_utf8_lossy(body.as_ref()).as_ref(),
                    )
                    .unwrap()
                }))
            } else {
                Box::new(
                    response.buffer().from_err().and_then(|response| {
                        Err(CreateStreamProcessorError::from_response(response))
                    }),
                )
            }
        })
    }
/// <p>Creates an Amazon Rekognition stream processor that you can use to detect and recognize faces in a streaming video.</p> <p>Amazon Rekognition Video is a consumer of live video from Amazon Kinesis Video Streams. Amazon Rekognition Video sends analysis results to Amazon Kinesis Data Streams.</p> <p>You provide as input a Kinesis video stream (<code>Input</code>) and a Kinesis data stream (<code>Output</code>) stream. You also specify the face recognition criteria in <code>Settings</code>. For example, the collection containing faces that you want to recognize. Use <code>Name</code> to assign an identifier for the stream processor. You use <code>Name</code> to manage the stream processor. For example, you can start processing the source video by calling with the <code>Name</code> field. </p> <p>After you have finished analyzing a streaming video, use to stop processing. You can delete the stream processor by calling .</p>
Creates an Amazon Rekognition stream processor that you can use to detect and recognize faces in a streaming video. Amazon Rekognition Video is a consumer of live video from Amazon Kinesis Video Streams. Amazon Rekognition Video sends analysis results to Amazon Kinesis Data Streams. You provide as input a Kinesis video stream (Input) and a Kinesis data stream (Output) stream. You also specify the face recognition criteria in Settings. For example, the collection containing faces that you want to recognize. Use Name to assign an identifier for the stream processor. You use Name to manage the stream processor. For example, you can start processing the source video by calling with the Name field.  After you have finished analyzing a streaming video, use to stop processing. You can delete the stream processor by calling .
Creates an Amazon Rekognition stream processor that you can use to detect and recognize faces in a streaming video . Amazon Rekognition Video is a consumer of live video from Amazon Kinesis Video Streams . Amazon Rekognition Video sends analysis results to Amazon Kinesis Data Streams . You provide as input a Kinesis video stream ( Input ) and a Kinesis data stream ( Output ) stream . You also specify the face recognition criteria in Settings . For example the collection containing faces that you want to recognize . Use Name to assign an identifier for the stream processor . You use Name to manage the stream processor . For example you can start processing the source video by calling with the Name field . After you have finished analyzing a streaming video use to stop processing . You can delete the stream processor by calling .
fn create_stream_processor(
        &self,
        input: CreateStreamProcessorRequest,
    ) -> RusotoFuture<CreateStreamProcessorResponse, CreateStreamProcessorError> {
        let mut request = SignedRequest::new("POST", "rekognition", &self.region, "/");
        request.set_content_type("application/x-amz-json-1.1".to_owned());
        request.add_header("x-amz-target", "RekognitionService.CreateStreamProcessor");
        let encoded = serde_json::to_string(&input).unwrap();
        request.set_payload(Some(encoded.into_bytes()));
        self.client.sign_and_dispatch(request, |response| {
            if response.status.is_success() {
                Box::new(response.buffer().from_err().map(|response| {
                    let mut body = response.body;
                    if body.is_empty() || body == b"null" {
                        body = b"{}".to_vec();
                    }
                    serde_json::from_str::<CreateStreamProcessorResponse>(
                        String::from_utf8_lossy(body.as_ref()).as_ref(),
                    )
                    .unwrap()
                }))
            } else {
                Box::new(
                    response.buffer().from_err().and_then(|response| {
                        Err(CreateStreamProcessorError::from_response(response))
                    }),
                )
            }
        })
    }
fn create_stream_processor ( & self , input : CreateStreamProcessorRequest , ) -> RusotoFuture < CreateStreamProcessorResponse , CreateStreamProcessorError > { let mut request = SignedRequest :: new ( " " , " " , & self . region , " " ) ; request . set_content_type ( " " . to_owned ( ) ) ; request . add_header ( " " , " " ) ; let encoded = serde_json :: to_string ( & input ) . unwrap ( ) ; request . set_payload ( Some ( encoded . into_bytes ( ) ) ) ; self . client . sign_and_dispatch ( request , | response | { if response . status . is_success ( ) { Box :: new ( response . buffer ( ) . from_err ( ) . map ( | response | { let mut body = response . body ; if body . is_empty ( ) || body == b" " { body = b" " . to_vec ( ) ; } serde_json :: from_str :: < CreateStreamProcessorResponse > ( String :: from_utf8_lossy ( body . as_ref ( ) ) . as_ref ( ) , ) . unwrap ( ) } ) ) } else { Box :: new ( response . buffer ( ) . from_err ( ) . and_then ( | response | { Err ( CreateStreamProcessorError :: from_response ( response ) ) } ) , ) } } ) }
<p>Creates an Amazon Rekognition stream processor that you can use to detect and recognize faces in a streaming video.</p> <p>Amazon Rekognition Video is a consumer of live video from Amazon Kinesis Video Streams.
<p > Creates an Amazon Rekognition stream processor that you can use to detect and recognize faces in a streaming video . < / p > <p > Amazon Rekognition Video is a consumer of live video from Amazon Kinesis Video Streams .
&self
input
CreateStreamProcessorRequest
&self
input
CreateStreamProcessorRequest