What is the best way to pause a JavaScript JSON stream for 60 seconds?

Question

What is the best way to pause a JavaScript JSON stream for 60 seconds?

I have been tasked with creating a JavaScript program that retrieves an API JSON record from a specific address every minute through a WebSocket. The stream should continue after 60 seconds, and I need to return both the current stream and the previous one that was retrieved. Below is the code I have written:

var obj= 
{
    seconds : 60,
    priv : 0,
    prevTick : '' ,
    data : ''
}

function countTime()
{
    obj.seconds --;
    obj.priv ++;
    var message ;
    if(obj.priv > 1)
    {
        obj.priv = 0;
        obj.message = null;
    }
    if(prop.seconds < 0)
    {
        message = sock.open();

        obj.message = obj.message + ", New Tick : " + message.message ; 
        setTimeout(countTime, 1000);
        obj.seconds = 60;
    }

}

var sock= new WebSocket('link');


sock.onopen = function(evt) {
    ws.send(JSON.stringify({ticks:'string'}));
};

sock.onmessage = function(msg) {
   var data = JSON.parse(msg.data);
   return 'record update: %o'+ data ;

};

Can someone please help me identify what is incorrect in my code above? It doesn't seem to be delaying as expected, and the stream continues continuously.

javascript json

Answer 1

Answer №1

Have you considered creating a class to manage the buffering functionality?

class SocketBuffer {
    constructor(socket, delay, ontick) {
        this.messages = [];
        let tickInterval;

        socket.onmessage = function(msg) {
            this.messages.push( JSON.parse(msg.data) );
        };

        function tick() {
            if (typeof ontick !== "function") return;
            ontick( this.messages.splice(0) );
        }

        this.pause = function () {
            tickInterval = clearInterval(tickInterval);
        };
        this.run = function () {
            if (tickInterval) return;
            tickInterval = setInterval(tick, delay * 1000);
            tick();
        };
        this.run();
    }
}

It's important to note that .splice(0) will extract all elements from the array and clear it in one step.

Example:

const link = new WebSocket('link');
link.onopen = function (evt) {
    this.send( JSON.stringify({ticks:'string'}) );
};

const linkBuf = new SocketBuffer(link, 60, function (newMessages) {
    console.log(newMessages);
});

// If necessary, you can:
linkBuf.pause();
linkBuf.run();

Answer 2

Have you considered creating a class to manage the buffering functionality?

class SocketBuffer {
    constructor(socket, delay, ontick) {
        this.messages = [];
        let tickInterval;

        socket.onmessage = function(msg) {
            this.messages.push( JSON.parse(msg.data) );
        };

        function tick() {
            if (typeof ontick !== "function") return;
            ontick( this.messages.splice(0) );
        }

        this.pause = function () {
            tickInterval = clearInterval(tickInterval);
        };
        this.run = function () {
            if (tickInterval) return;
            tickInterval = setInterval(tick, delay * 1000);
            tick();
        };
        this.run();
    }
}

It's important to note that .splice(0) will extract all elements from the array and clear it in one step.

Example:

const link = new WebSocket('link');
link.onopen = function (evt) {
    this.send( JSON.stringify({ticks:'string'}) );
};

const linkBuf = new SocketBuffer(link, 60, function (newMessages) {
    console.log(newMessages);
});

// If necessary, you can:
linkBuf.pause();
linkBuf.run();

Answer 3

Answer №2

Give this a shot:

function calculateDuration() {
    var timeInterval = 1000; // Time interval between each calculation
    // setInterval continues to run indefinitely unless stopped with clearInterval
    var timer = setInterval(function () {
        // Insert your code here

        // End the loop if needed
        clearInterval(timer);
    }, timeInterval);
}

Answer 4

Give this a shot:

function calculateDuration() {
    var timeInterval = 1000; // Time interval between each calculation
    // setInterval continues to run indefinitely unless stopped with clearInterval
    var timer = setInterval(function () {
        // Insert your code here

        // End the loop if needed
        clearInterval(timer);
    }, timeInterval);
}

Answer 5

Answer №3

By utilizing setTimeout(), you can automate the process without manually tracking seconds. For tasks that need to be repeated periodically, it is recommended to use setInterval() as advised by @RyanB. On the other hand, setTimeout() is more suitable for one-time tasks. It appears that you are referencing prop.seconds without defining the variable prop. Remember to include a call to countTime() somewhere in your code to ensure its execution.

An improved version may look like this:

var obj= 
{
    seconds : 60,
    priv : 0,
    prevTick : '' ,
    data : ''
}

function countTime()
{
    obj.seconds --;
    obj.priv ++; //It seems redundant to set it back to zero 3 lines later
    var msg ;
    if(obj.priv > 1)
    {
        obj.priv = 0;
        obj.msg = null;
    }
    msg = sock.open();
    obj.msg = obj.msg + ", New Tick : " + msg.msg; 
    obj.seconds = 60;
    //Consider calling sock.close() here
}

var sock= new WebSocket('link');

sock.onopen = function(evt) {
    ws.send(JSON.stringify({ticks:'string'}));
};

sock.onmessage = function(msg) {
   var data = JSON.parse(msg.data);
   return 'record update: %o'+ data ;

};
var interval = setInterval(countTime, 1000);

EDIT: Once completed, use

clearInterval(interval);

to terminate the program's execution.

Answer 6

By utilizing setTimeout(), you can automate the process without manually tracking seconds. For tasks that need to be repeated periodically, it is recommended to use setInterval() as advised by @RyanB. On the other hand, setTimeout() is more suitable for one-time tasks. It appears that you are referencing prop.seconds without defining the variable prop. Remember to include a call to countTime() somewhere in your code to ensure its execution.

An improved version may look like this:

var obj= 
{
    seconds : 60,
    priv : 0,
    prevTick : '' ,
    data : ''
}

function countTime()
{
    obj.seconds --;
    obj.priv ++; //It seems redundant to set it back to zero 3 lines later
    var msg ;
    if(obj.priv > 1)
    {
        obj.priv = 0;
        obj.msg = null;
    }
    msg = sock.open();
    obj.msg = obj.msg + ", New Tick : " + msg.msg; 
    obj.seconds = 60;
    //Consider calling sock.close() here
}

var sock= new WebSocket('link');

sock.onopen = function(evt) {
    ws.send(JSON.stringify({ticks:'string'}));
};

sock.onmessage = function(msg) {
   var data = JSON.parse(msg.data);
   return 'record update: %o'+ data ;

};
var interval = setInterval(countTime, 1000);

EDIT: Once completed, use

clearInterval(interval);

to terminate the program's execution.

What is the best way to pause a JavaScript JSON stream for 60 seconds?

Answer №1

Answer №2

Answer №3

Similar questions

"Encountering Validation Error while Transmitting JSON Data through AJAX with NodeJS and M

The 'AutocompleteDirectionsHandler' cannot be utilized until the Google Api has been initialized

Tips for troubleshooting the StaleElementReferenceError in selenium automation

Maximizing the efficiency of this JavaScript code

Initiate jison states using JSON structure

Issue with div data-anchors not functioning unless the entire page is reloaded

The mapDispatchToProps function is failing to work, throwing an error: Uncaught TypeError: _this.props.addCountdown is not a function

Leveraging Vue.js plugin within a single file component

What is the best way to compare the lengths of all nested child elements with each other?

Discover the power of uploading images using HTML5 with PHP

Puppeteer encounters difficulty when attempting to click on a particular div element within Gmail

One way to transfer data from a Vue table component to another Vue table component is by including an edit button on each row in the table. This allows

Comparing elements in one array to elements in another array

What is the best way to ensure that this JavaScript code functions properly when dealing with business operating hours

Utilizing jQuery event delegation with the use of .on and the unique reference of (

JavaScript getter function is returning undefined even though it functions properly during the initial invocation

Nuxt.js transition issue: How to fix transitions not working

Determining if a JavaScript variable points to another variable

What is the best way to insert values from an array into a row?

Error in Node REPL: Trying to access property '0' of undefined after adding a property to Object.prototype