1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
require 'rubygems'
require 'plivo'

include Plivo
include Plivo::Exceptions

api = RestClient.new("<auth_id>","<auth_token>")

begin
  response = api.calls.start_stream( "227ff3c3-1562-4316-819f-217f638890f6","wss://www.example.com/socketserver",
      {
        
        bidirectional: false,
        audio_track: "both",
        stream_timeout: 86400,
        status_callback_url: "https://<yourdomain>.com/events/",
        status_callback_method: "POST",
        content_type: "audio/x-l16;rate=16000",
        extra_headers: "Test1=Test2,Test3=Test4"
        }
    )
  puts response
rescue PlivoRESTError => e
  puts 'Exception: ' + e.message
end

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
// Create an audio stream on a call

'use strict';

var plivo = require('plivo');

(function main() {
    var client = new plivo.Client(<auth_id>, <auth_token>);
    client.calls.stream(<call_uuid>, "wss://www.example.com/socketserver",
        {
            bidirectional: false,
            audioTrack: "both",
            streamTimeout: 86400,
            statusCallbackMethod: "POST",
            contentType: "audio/x-l16;rate=16000"
        }
    ).then(function (response) {
        console.log(response);
    }, function (err) {
        console.error(err);
    });
})();

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
<?php
/**
 * Create an audio stream on a call
 */
require 'vendor/autoload.php';
use Plivo\RestClient;
use Plivo\Exceptions\PlivoRestException;
$client = new RestClient("<auth_id>","<auth_token>");
try {
    
    $response = $client->calls->startStream(
        "d08b6798-c8eb-4dad-b8c5-4e8d2bdb718a",
        array('service_url'=>"wss://www.example.com/socketserver",
        'bidirectional' => false,
        'audio_track' => "both",
        'stream_timeout' => 86400,
        'status_callback_url' => "https://<yourdomain>.com/confevents/",
        'status_callback_method' => "POST",
        'content_type' => "audio/x-l16;rate=16000",
        'extraheaders' =>"Test1=Test2,Test3=Test4"

    )
    );

    print_r($response);
}
catch (PlivoRestException $ex) {
    print_r($ex);
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package com.plivo.examples.audioStream;

import java.io.IOException;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;

import com.plivo.api.Plivo;
import com.plivo.api.exceptions.PlivoRestException;
import com.plivo.api.models.call.Call;
import com.plivo.api.models.call.CallCreateResponse;
import com.plivo.api.models.call.actions.CallStreamCreateResponse;
import com.plivo.api.models.call.actions.CallStreamCreator;

/**
 * Create an audio stream on a call
 */
class createStreamAPI {

  public static void main(String [] args) {

    Plivo.init("MANWVLYTK4ZWU1YTY4QA", "ZDI4ZTc3ZWNmMzJhM2M2OGI4MGVjZmJmNmFjNDRl");

    Map map=new HashMap();
    map.put(1,"Amit");


    try {
      CallStreamCreateResponse response = Call.streamer("874a6bfa-da76-4279-b8c5-2d12743c045b","wss://ea22-120-138-116-194.ngrok.io")
        .streamTimeout(23).bidirectional(false).audioTrack("both").statusCallbackUrl("http://plivobin.non-prod.plivops.com/1pdc8e11").statusCallbackMethod("POST").contentType("audio/x-l16;rate=16000").extraHeaders("Test1=Test2,Test3=Test4").stream();
      System.out.println(response);

    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/**
 * Create an audio stream on a call
 */
using System;
using System.Collections.Generic;
using Plivo;
using Plivo.Exception;

namespace PlivoExamples
{
    internal class Program
    {
        public static void Main(string[] args)
        {
            var api = new PlivoApi("<auth_id>","<auth_token>");
            try
            {
                var response = api.Call.StartStream(callUuid: "d08b6798-c8eb-4dad-b8c5-4e8d2bdb718a", serviceUrl: "wss://www.example.com/socketserver",
                                    bidirectional: "False", audioTrack: "both",
                                    streamTimeout: "86400",statusCallbackMethod: "POST", statusCallbackUrl: "https://<yourdomain>.com/confevents/", contentType: "audio/x-l16;rate=16000",
                                    extraHeaders: "Test1=Test2,Test3=Test4");
                );
                Console.WriteLine(response);
            }
            catch (PlivoRestException e)
            {
                Console.WriteLine("Exception: " + e.Message);
            }
        }
    }
}

1
2
3
4
curl -i --user AUTH_ID:AUTH_TOKEN \
    -H "Content-Type: application/json" \
    -d '{"service_url": "wss://mystream.ngrok.io/audiostream","bidirectional": true,"status_callback_url": "https://webhook.site/22ffd771-4337-4f5e-b9e0-00c24bd2c119"}' \
    https://api.plivo.com/v1/Account/{auth_id}/Call/{call_uuid}/Stream/

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
package Audio_Streaming

import (
"fmt"
"github.com/plivo/plivo-go/v7"
)

// Create an audio stream on a call
//package main

func main() {
client, err := plivo.NewClient("<auth_id>", "<auth_token>", &plivo.ClientOptions{})
if err != nil {
fmt.Print("Error", err.Error())
return
}
//Method for create Stream
response , err := client.Calls.Stream("14885f81-ecb5-477d-a361-930276352966", plivo.CallStreamParams{

ServiceUrl: "wss://a33b-120-138-116-194.ngrok.io",
Bidirectional: false,
AudioTrack: "both",
StreamTimeout: 300,
StatusCallbackMethod: "POST",
StatusCallbackUrl: "http://plivobin.non-prod.plivops.com/1pdc8e11",
ContentType: "audio/x-l16;rate=16000",
ExtraHeaders : "Test1=Test2,Test3=Test4"
},
)
if err != nil {
fmt.Print("Error", err.Error())
return
}
fmt.Printf("Response: %#v\n", response)
}