How to get last value repeated for a path on the server?

[VladimirKalachikhin]

The app.streambundle.getSelfStream(path) function returns the path value by event in the patn.
Is there any way to get values by event, and if there are none, then at a specified time interval?

[tkurki]

Sorry, I don’t understand your question. What is it that you’d like to happen?

[VladimirKalachikhin]

I want to receive data periodically, even if there is none. That is, if there are no events in the stream, I want the event handling function to be executed periodically anyway.

It's easy in PHP, but I haven't found a way here.

[tkurki]

Beware that there may be several sources producing data for a single path, so sending repeatedly the latest value may or may not be what you want.

I don't know what you need it for, but this seems something you'd do in your application/plugin, not as part of the server API.

Gemini's solution:

function repeatLast(source, interval) {
  let lastValue = null;
  let lastUpdate = 0;

  const newValues = source.flatMapLatest(value => {
    lastValue = value;
    lastUpdate = Bacon.scheduler.now();
    return Bacon.once(value);
  });

  const repeatValues = Bacon.interval(interval, null)
    .filter(() => Bacon.scheduler.now() - lastUpdate >= interval && lastValue !== null)
    .map(() => lastValue);

  return newValues.merge(repeatValues);
}
// ===========================

// Example usage:
const source = new Bacon.Bus();

const repeatedStream = repeatLast(source.toProperty(), 1000); // Repeat every 1000ms

repeatedStream.onValue(value => {
  console.log("Received:", value);
});

source.push("A");
setTimeout(() => {
  source.push("B");
}, 2000);

setTimeout(() => {
  // no new data for a while, so "B" should repeat
}, 3500);

setTimeout(() => {
  source.push("C");
}, 5500);

setTimeout(() => {
  // no new data for a while, so "C" should repeat
}, 7000);

[VladimirKalachikhin]

Thanks, but I just need it applied to the server API...

Ok, no is no. We'll do as we can, not as we should. Or don't do it at all.

[tkurki]

Well, I provided the code, you need to use it and ”apply it to the server api”.