mirror of
https://gitlab.futo.org/videostreaming/grayjay.git
synced 2025-09-17 15:02:34 +00:00
Additional locking
This commit is contained in:
parent
b953ff21e7
commit
c0bbe5d491
2 changed files with 13 additions and 8 deletions
|
@ -346,8 +346,10 @@ open class JSClient : IPlatformClient {
|
||||||
return _searchCapabilities!!;
|
return _searchCapabilities!!;
|
||||||
}
|
}
|
||||||
|
|
||||||
_searchCapabilities = ResultCapabilities.fromV8(config, plugin.executeTyped("source.getSearchCapabilities()"));
|
return busy {
|
||||||
return _searchCapabilities!!;
|
_searchCapabilities = ResultCapabilities.fromV8(config, plugin.executeTyped("source.getSearchCapabilities()"));
|
||||||
|
return@busy _searchCapabilities!!;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
catch(ex: Throwable) {
|
catch(ex: Throwable) {
|
||||||
announcePluginUnhandledException("getSearchCapabilities", ex);
|
announcePluginUnhandledException("getSearchCapabilities", ex);
|
||||||
|
@ -375,8 +377,10 @@ open class JSClient : IPlatformClient {
|
||||||
if (_searchChannelContentsCapabilities != null)
|
if (_searchChannelContentsCapabilities != null)
|
||||||
return _searchChannelContentsCapabilities!!;
|
return _searchChannelContentsCapabilities!!;
|
||||||
|
|
||||||
_searchChannelContentsCapabilities = ResultCapabilities.fromV8(config, plugin.executeTyped("source.getSearchChannelContentsCapabilities()"));
|
return busy {
|
||||||
return _searchChannelContentsCapabilities!!;
|
_searchChannelContentsCapabilities = ResultCapabilities.fromV8(config, plugin.executeTyped("source.getSearchChannelContentsCapabilities()"));
|
||||||
|
return@busy _searchChannelContentsCapabilities!!;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@JSDocs(5, "source.searchChannelContents(query)", "Searches for videos on the platform")
|
@JSDocs(5, "source.searchChannelContents(query)", "Searches for videos on the platform")
|
||||||
@JSDocsParameter("channelUrl", "Channel url to search")
|
@JSDocsParameter("channelUrl", "Channel url to search")
|
||||||
|
@ -433,9 +437,10 @@ open class JSClient : IPlatformClient {
|
||||||
if (_channelCapabilities != null) {
|
if (_channelCapabilities != null) {
|
||||||
return _channelCapabilities!!;
|
return _channelCapabilities!!;
|
||||||
}
|
}
|
||||||
|
return busy {
|
||||||
_channelCapabilities = ResultCapabilities.fromV8(config, plugin.executeTyped("source.getChannelCapabilities()"));
|
_channelCapabilities = ResultCapabilities.fromV8(config, plugin.executeTyped("source.getChannelCapabilities()"));
|
||||||
return _channelCapabilities!!;
|
return@busy _channelCapabilities!!;
|
||||||
|
};
|
||||||
}
|
}
|
||||||
catch(ex: Throwable) {
|
catch(ex: Throwable) {
|
||||||
announcePluginUnhandledException("getChannelCapabilities", ex);
|
announcePluginUnhandledException("getChannelCapabilities", ex);
|
||||||
|
|
|
@ -15,7 +15,7 @@ class JSLiveEventPager : JSPager<IPlatformLiveEvent>, IPlatformLiveEventPager {
|
||||||
nextRequest = pager.getOrThrow(config, "nextRequest", "LiveEventPager");
|
nextRequest = pager.getOrThrow(config, "nextRequest", "LiveEventPager");
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun nextPage() {
|
override fun nextPage() = plugin.isBusyWith("JSLiveEventPager.nextPage") {
|
||||||
super.nextPage();
|
super.nextPage();
|
||||||
nextRequest = pager.getOrThrow(config, "nextRequest", "LiveEventPager");
|
nextRequest = pager.getOrThrow(config, "nextRequest", "LiveEventPager");
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue